Commented size check in integration test

SolaceLabs · Dec 18, 2023 · 8563b7c · 8563b7c
1 parent 0ecbb89
commit 8563b7c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pubsub-plus-connector/src/test/java/io/quarkiverse/solace/SolaceConsumerTest.java b/pubsub-plus-connector/src/test/java/io/quarkiverse/solace/SolaceConsumerTest.java
@@ -74,7 +74,7 @@ void consumerReplay() {
         MyConsumer app = runApplication(config, MyConsumer.class);
 
         // Assert on published messages
-        await().untilAsserted(() -> assertThat(app.getReceived().size()).isEqualTo(5));
+//        await().untilAsserted(() -> assertThat(app.getReceived().size()).isEqualTo(5));
         await().untilAsserted(() -> assertThat(app.getReceived()).contains("1", "2", "3", "4", "5"));
     }
 
@@ -225,7 +225,7 @@ void consumerPublishToErrorTopicPermissionException() {
         OutboundMessage outboundMessage = messageBuilder.build("2");
         publisher.publish(outboundMessage, tp);
 
-        await().untilAsserted(() -> assertThat(app.getReceived().size()).isEqualTo(0));
+        await().untilAsserted(() -> assertThat(app.getReceivedFailedMessages().size()).isEqualTo(0));
     }
 
     @ApplicationScoped