[camel-kafka-connector] branch main updated: Return ealier from SJMS test to avoid locking the test

[orpiske]

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

orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git


The following commit(s) were added to refs/heads/main by this push:
     new 84d851b  Return ealier from SJMS test to avoid locking the test
84d851b is described below

commit 84d851b5eb076774496438dc4853936e844bc751
Author: Otavio Rodolfo Piske <opi...@redhat.com>
AuthorDate: Mon Apr 26 16:21:32 2021 +0200

    Return ealier from SJMS test to avoid locking the test
---
 .../apache/camel/kafkaconnector/sjms2/sink/CamelSinkJMSITCase.java   | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/sink/CamelSinkJMSITCase.java
 
b/tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/sink/CamelSinkJMSITCase.java
index b56c580..0787f8c 100644
--- 
a/tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/sink/CamelSinkJMSITCase.java
+++ 
b/tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/sink/CamelSinkJMSITCase.java
@@ -99,6 +99,7 @@ public class CamelSinkJMSITCase extends CamelSinkTestSupport {
                 received++;
 
                 if (received == expect) {
+                    LOG.debug("All messages were received");
                     return false;
                 }
 
@@ -121,9 +122,7 @@ public class CamelSinkJMSITCase extends 
CamelSinkTestSupport {
 
             jmsClient.start();
             try (MessageConsumer consumer = 
jmsClient.createConsumer(SJMS2Common.DEFAULT_JMS_QUEUE)) {
-                for (int i = 0; i < expect; i++) {
-                    jmsClient.receive(consumer, this::checkRecord);
-                }
+                jmsClient.receive(consumer, this::checkRecord);
             }
 
         } catch (Exception e) {