[camel-kafka-connector] 02/05: Avoid reusing the same destination name for the sjms2 idempotency tests

[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 55ca7a2d4d205a78404696a8bd3781d66869b876
Author: Otavio Rodolfo Piske <opi...@redhat.com>
AuthorDate: Wed Feb 3 08:46:56 2021 +0100

    Avoid reusing the same destination name for the sjms2 idempotency tests
---
 .../kafkaconnector/sjms2/sink/CamelSinkIdempotentJMSITCase.java     | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/sink/CamelSinkIdempotentJMSITCase.java
 
b/tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/sink/CamelSinkIdempotentJMSITCase.java
index 8eceee2..566e823 100644
--- 
a/tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/sink/CamelSinkIdempotentJMSITCase.java
+++ 
b/tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/sink/CamelSinkIdempotentJMSITCase.java
@@ -62,6 +62,7 @@ public class CamelSinkIdempotentJMSITCase extends 
AbstractKafkaTest {
     private static final Logger LOG = 
LoggerFactory.getLogger(CamelSinkIdempotentJMSITCase.class);
 
     private String topic;
+    private String destinationName;
     private int received;
     private final int expect = 10;
 
@@ -84,6 +85,7 @@ public class CamelSinkIdempotentJMSITCase extends 
AbstractKafkaTest {
         LOG.info("JMS service running at {}", jmsService.defaultEndpoint());
         received = 0;
         topic = TestUtils.getDefaultTestTopic(this.getClass());
+        destinationName = SJMS2Common.DEFAULT_JMS_QUEUE + "-" + 
TestUtils.randomWithRange(0, 100);
     }
 
     private boolean checkRecord(Message jmsMessage) {
@@ -111,7 +113,7 @@ public class CamelSinkIdempotentJMSITCase extends 
AbstractKafkaTest {
             jmsClient = JMSClient.newClient(jmsService.defaultEndpoint());
             jmsClient.start();
 
-            try (MessageConsumer consumer = 
jmsClient.createConsumer(SJMS2Common.DEFAULT_JMS_QUEUE)) {
+            try (MessageConsumer consumer = 
jmsClient.createConsumer(destinationName)) {
                 // number of retries until stale
                 int retries = 10;
 
@@ -176,7 +178,7 @@ public class CamelSinkIdempotentJMSITCase extends 
AbstractKafkaTest {
                     .basic()
                     .withTopics(topic)
                     .withConnectionProperties(connectionProperties())
-                    .withDestinationName(SJMS2Common.DEFAULT_JMS_QUEUE)
+                    .withDestinationName(destinationName)
                     .withIdempotency()
                         .withRepositoryType("memory")
                         .withExpressionType("body")