[camel-kafka-connector] 05/05: SJMS2 itests: Avoid creating a new consumer for every message received

[acosentino]

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

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

commit ad8d0a97afe82e7bc451491b0225746319666342
Author: Otavio Rodolfo Piske <opi...@redhat.com>
AuthorDate: Wed Feb 3 08:36:34 2021 +0100

    SJMS2 itests: Avoid creating a new consumer for every message received
---
 .../camel/kafkaconnector/sjms2/sink/CamelSinkJMSITCase.java       | 8 +++++---
 1 file changed, 5 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 c67bba6..41b87a8 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
@@ -26,6 +26,7 @@ import java.util.concurrent.TimeUnit;
 
 import javax.jms.JMSException;
 import javax.jms.Message;
+import javax.jms.MessageConsumer;
 import javax.jms.TextMessage;
 
 import org.apache.camel.kafkaconnector.common.AbstractKafkaTest;
@@ -175,9 +176,10 @@ public class CamelSinkJMSITCase extends AbstractKafkaTest {
             jmsClient = JMSClient.newClient(jmsService.defaultEndpoint());
 
             jmsClient.start();
-
-            for (int i = 0; i < expect; i++) {
-                jmsClient.receive(SJMS2Common.DEFAULT_JMS_QUEUE, 
this::checkRecord);
+            try (MessageConsumer consumer = 
jmsClient.createConsumer(SJMS2Common.DEFAULT_JMS_QUEUE)) {
+                for (int i = 0; i < expect; i++) {
+                    jmsClient.receive(consumer, this::checkRecord);
+                }
             }
 
         } catch (Exception e) {