Skip to content

Commit 89d8d3d

Browse files
committed
fix: race condition
Signed-off-by: Marcos Tischer Vallim <tischer@gmail.com>
1 parent 1eeb785 commit 89d8d3d

3 files changed

Lines changed: 2 additions & 154 deletions

File tree

amazon-sns-java-messaging-lib-v1/src/test/java/com/amazon/sns/messaging/lib/core/jmh/AmazonSnsTemplateBenchmark.java

Lines changed: 0 additions & 127 deletions
This file was deleted.

amazon-sns-java-messaging-lib-v1/src/test/java/com/amazon/sns/messaging/lib/core/jmh/AmazonSnsTemplateBenchmarkRunner.java

Lines changed: 0 additions & 25 deletions
This file was deleted.

amazon-sns-java-messaging-lib-v2/src/test/java/com/amazon/sns/messaging/lib/core/AmazonSnsProducerAsyncTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -163,12 +163,12 @@ void testFailureMultipleEntry() {
163163
assertThat(result, notNullValue());
164164
}));
165165

166-
entries(3000000).forEach(entry -> {
166+
entries(30000).forEach(entry -> {
167167
snsTemplate.send(entry).addCallback(null, failureCallback);
168168
});
169169

170170
snsTemplate.await().thenAccept(result -> {
171-
verify(failureCallback, timeout(300000).times(3000000)).accept(any());
171+
verify(failureCallback, timeout(300000).times(30000)).accept(any());
172172
verify(amazonSNS, atLeastOnce()).publishBatch(any(PublishBatchRequest.class));
173173
}).join();
174174
}

0 commit comments

Comments
 (0)