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

Fix timing issue in the KinesisMDChATests

Browse Source 
https://build.spring.io/browse/INTEXT-AWS-157
This commit is contained in:
Artem Bilan
2018-06-26 15:21:56 -04:00
parent 133731f288
commit 4fe8e4c6a5
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -158,11 +158,11 @@ public class KinesisMessageDrivenChannelAdapterTests {
TestUtils.getPropertyValue(this.kinesisMessageDrivenChannelAdapter,
"shardLocksMonitor.forLocking", Map.class);
Assert.assertThat(0, eventually(equalsResult(forLocking::size)));
Assert.assertThat(0, eventually(100, 100, equalsResult(forLocking::size)));
List consumerInvoker =
List consumerInvokers =
TestUtils.getPropertyValue(this.kinesisMessageDrivenChannelAdapter, "consumerInvokers", List.class);
Assert.assertThat(0, eventually(equalsResult(consumerInvoker::size)));
Assert.assertThat(0, eventually(100, 100, equalsResult(consumerInvokers::size)));
this.kinesisMessageDrivenChannelAdapter.setListenerMode(ListenerMode.batch);
this.kinesisMessageDrivenChannelAdapter.setCheckpointMode(CheckpointMode.record);
@@ -187,12 +187,12 @@ public class KinesisMessageDrivenChannelAdapterTests {
assertThat((List<String>) sequenceNumberHeader).contains("2");
Assert.assertThat("2",
eventually(equalsResult(() ->
eventually(100, 100, equalsResult(() ->
this.checkpointStore.get("SpringIntegration" + ":" + STREAM1 + ":" + "1"))));
consumerInvoker =
consumerInvokers =
TestUtils.getPropertyValue(this.kinesisMessageDrivenChannelAdapter, "consumerInvokers", List.class);
assertThat(consumerInvoker.size()).isEqualTo(2);
assertThat(consumerInvokers.size()).isEqualTo(2);
this.kinesisMessageDrivenChannelAdapter.stop();
}