(pulsar-client-reactive) branch main updated: [Release 0.5.3] Update version to 0.5.3 (#161)

[lhotari]

This is an automated email from the ASF dual-hosted git repository.

lhotari pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git


The following commit(s) were added to refs/heads/main by this push:
     new 8c8d087  [Release 0.5.3] Update version to 0.5.3 (#161)
8c8d087 is described below

commit 8c8d087abaa04c413150d6931451996e9fad8c2c
Author: Chris Bono <cb...@vmware.com>
AuthorDate: Fri Feb 16 00:00:39 2024 -0600

    [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 <on...@apache.org>
---
 gradle.properties                                                       | 2 +-
 .../client/internal/adapter/AdaptedReactiveMessageConsumerTests.java    | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/gradle.properties b/gradle.properties
index a751da5..f08e395 100644
--- a/gradle.properties
+++ b/gradle.properties
@@ -17,4 +17,4 @@
 # under the License.
 #
 
-version=0.5.2
+version=0.5.3
diff --git 
a/pulsar-client-reactive-adapter/src/test/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageConsumerTests.java
 
b/pulsar-client-reactive-adapter/src/test/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageConsumerTests.java
index 96babd1..2fbc7da 100644
--- 
a/pulsar-client-reactive-adapter/src/test/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageConsumerTests.java
+++ 
b/pulsar-client-reactive-adapter/src/test/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageConsumerTests.java
@@ -366,7 +366,7 @@ class AdaptedReactiveMessageConsumerTests {
 
                StepVerifier
                        .create(reactiveConsumer.consumeMany((messages) -> 
messages.map(MessageResult::acknowledgeAndReturn))
-                               .take(Duration.ofMillis(100)))
+                               .take(Duration.ofMillis(200)))
                        .expectNext(message1)
                        .expectNext(message2)
                        .verifyComplete();