Skip to content

Commit

Permalink
Fix flaky AdaptedReactiveMessageConsumerTests
Browse files Browse the repository at this point in the history
The consumeManyAndAcknowledge() tests has been flaky. This commit
increase the `take` window from 100ms to 200ms to allow the messages to
be emitted.
  • Loading branch information
onobc committed Feb 16, 2024
1 parent 0d01926 commit b91f49d
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -366,7 +366,7 @@ void consumeManyAndAcknowledge() throws Exception {

StepVerifier
.create(reactiveConsumer.consumeMany((messages) -> messages.map(MessageResult::acknowledgeAndReturn))
.take(Duration.ofMillis(100)))
.take(Duration.ofMillis(200)))
.expectNext(message1)
.expectNext(message2)
.verifyComplete();
Expand Down

0 comments on commit b91f49d

Please sign in to comment.