Spring/spring-integration-aws
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix race condition in the KinesisMDChATests

Browse Source
This commit is contained in:
Artem Bilan
2018-06-26 13:34:01 -04:00
parent 8247d0df1b
commit 133731f288
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/test/java/org/springframework/integration/aws/inbound/KinesisMessageDrivenChannelAdapterTests.java
View File

@@ -160,6 +160,10 @@ public class KinesisMessageDrivenChannelAdapterTests {
Assert.assertThat(0, eventually(equalsResult(forLocking::size)));
List consumerInvoker =
TestUtils.getPropertyValue(this.kinesisMessageDrivenChannelAdapter, "consumerInvokers", List.class);
Assert.assertThat(0, eventually(equalsResult(consumerInvoker::size)));
this.kinesisMessageDrivenChannelAdapter.setListenerMode(ListenerMode.batch);
this.kinesisMessageDrivenChannelAdapter.setCheckpointMode(CheckpointMode.record);
this.checkpointStore.put("SpringIntegration" + ":" + STREAM1 + ":" + "1", "1");
@@ -186,7 +190,7 @@ public class KinesisMessageDrivenChannelAdapterTests {
eventually(equalsResult(() ->
this.checkpointStore.get("SpringIntegration" + ":" + STREAM1 + ":" + "1"))));
List consumerInvoker =
consumerInvoker =
TestUtils.getPropertyValue(this.kinesisMessageDrivenChannelAdapter, "consumerInvokers", List.class);
assertThat(consumerInvoker.size()).isEqualTo(2);