Skip to content

Commit 2d8f7d1

Browse files
committed
Fix race condition in the KinesisMDChannelAdapter
The `KinesisMessageDrivenChannelAdapter` may exit its `active` state, but `consumerInvokers` won't be cleared in the main consumer loop **Cherry-pick to master**
1 parent 3860df6 commit 2d8f7d1

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

src/main/java/org/springframework/integration/aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1191,6 +1191,9 @@ public void run() {
11911191
}
11921192
}
11931193
}
1194+
synchronized (KinesisMessageDrivenChannelAdapter.this.consumerInvokers) {
1195+
KinesisMessageDrivenChannelAdapter.this.consumerInvokers.remove(this);
1196+
}
11941197
}
11951198

11961199
@Override

0 commit comments

Comments
 (0)