Add message to test assertion

Author: acogoluegnes

src/main/java/com/rabbitmq/stream/impl/StreamProducerBuilder.java

@@ -28,8 +28,8 @@
 
 class StreamProducerBuilder implements ProducerBuilder {
 
-  static final boolean DEFAULT_DYNAMIC_BATCH =
-      Boolean.parseBoolean(System.getProperty("rabbitmq.stream.producer.dynamic.batch", "true"));
+  static final boolean DEFAULT_DYNAMIC_BATCH = true;
+//      Boolean.parseBoolean(System.getProperty("rabbitmq.stream.producer.dynamic.batch", "true"));
 
   private final StreamEnvironment environment;
 

src/test/java/com/rabbitmq/stream/impl/SuperStreamConsumerTest.java

@@ -330,7 +330,8 @@ void rebalancedPartitionShouldGetMessagesWhenItComesBackToOriginalConsumerInstan
                   processing.run();
                 })
             .build();
-    waitAtMost(() -> receivedPartitions.size() == partitions.size());
+    waitAtMost(() -> receivedPartitions.size() == partitions.size(),
+        () -> format("Expected to receive messages from all partitions, got %s", receivedPartitions));
 
     AtomicReference<String> partition = new AtomicReference<>();
     Consumer consumer2 =
@@ -352,7 +353,8 @@ void rebalancedPartitionShouldGetMessagesWhenItComesBackToOriginalConsumerInstan
     waitAtMost(() -> partition.get() != null);
     consumer2.close();
     receivedPartitions.clear();
-    waitAtMost(() -> receivedPartitions.size() == partitions.size());
+    waitAtMost(() -> receivedPartitions.size() == partitions.size(),
+        () -> format("Expected to receive messages from all partitions, got %s", receivedPartitions));
     consumer1.close();
   }
 }

src/test/java/com/rabbitmq/stream/impl/TestUtilsTest.java

@@ -16,18 +16,41 @@
 
 import static org.assertj.core.api.Assertions.assertThat;
 
+import java.util.concurrent.Executor;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.CsvSource;
 
 public class TestUtilsTest {
 
-  @ParameterizedTest
-  @CsvSource({
-    "3.9.6,3.9.5,false",
-    "3.9.6,3.9.0-alpha-stream.232,true",
-    "3.9.6,3.9.6-alpha.28,true"
-  })
-  void atLeastVersion(String expectedVersion, String currentVersion, boolean expected) {
-    assertThat(TestUtils.atLeastVersion(expectedVersion, currentVersion)).isEqualTo(expected);
-  }
+    @ParameterizedTest
+    @CsvSource(
+        {
+            "3.9.6,3.9.5,false",
+            "3.9.6,3.9.0-alpha-stream.232,true",
+            "3.9.6,3.9.6-alpha.28,true",
+        }
+    )
+    void atLeastVersion(
+        String expectedVersion,
+        String currentVersion,
+        boolean expected
+    ) {
+        assertThat(
+            TestUtils.atLeastVersion(expectedVersion, currentVersion)
+        ).isEqualTo(expected);
+    }
+
+    private static class DelegatingExecutor implements Executor {
+
+        private final Executor delegate;
+
+        private DelegatingExecutor(Executor delegate) {
+            this.delegate = delegate;
+        }
+
+        @Override
+        public void execute(Runnable command) {
+            delegate.execute(command);
+        }
+    }
 }