You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2021/02/03 09:28:39 UTC
[camel-kafka-connector] branch master updated: SJMS2 itests: Avoid
creating a new consumer for every message received
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 5bbb8fe SJMS2 itests: Avoid creating a new consumer for every message received
5bbb8fe is described below
commit 5bbb8febef19b88f1ead0a90548c05844bb8b714
Author: Otavio Rodolfo Piske <op...@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) {