Skip to content

Commit 8c8d087

Browse files
authored
[Release 0.5.3] Update version to 0.5.3 (#161)
* [Release 0.5.3] Update version to 0.5.3 * Fix flaky AdaptedReactiveMessageConsumerTests The consumeManyAndAcknowledge() tests has been flaky. This commit increase the `take` window from 100ms to 200ms to allow the messages to be emitted. --------- Co-authored-by: onobc <onobc@apache.org>
1 parent 26c5908 commit 8c8d087

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

gradle.properties

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,4 +17,4 @@
1717
# under the License.
1818
#
1919

20-
version=0.5.2
20+
version=0.5.3

pulsar-client-reactive-adapter/src/test/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageConsumerTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -366,7 +366,7 @@ void consumeManyAndAcknowledge() throws Exception {
366366

367367
StepVerifier
368368
.create(reactiveConsumer.consumeMany((messages) -> messages.map(MessageResult::acknowledgeAndReturn))
369-
.take(Duration.ofMillis(100)))
369+
.take(Duration.ofMillis(200)))
370370
.expectNext(message1)
371371
.expectNext(message2)
372372
.verifyComplete();

0 commit comments

Comments
 (0)