[camel-quarkus] branch main updated: Fix #2608 to create destination correctly and re-enable the test case

[ppalaga]

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

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


The following commit(s) were added to refs/heads/main by this push:
     new 8868834  Fix #2608 to create destination correctly and re-enable the 
test case
8868834 is described below

commit 8868834634fab390c44b5253f4ca5f56e24be4e8
Author: Amos Feng <zf...@redhat.com>
AuthorDate: Fri Jun 4 21:10:13 2021 +0800

    Fix #2608 to create destination correctly and re-enable the test case
---
 .../apache/camel/quarkus/component/messaging/it/JmsProducers.java  | 7 ++++++-
 .../org/apache/camel/quarkus/component/messaging/it/JmsTest.java   | 2 --
 2 files changed, 6 insertions(+), 3 deletions(-)

diff --git 
a/integration-tests/messaging/src/main/java/org/apache/camel/quarkus/component/messaging/it/JmsProducers.java
 
b/integration-tests/messaging/src/main/java/org/apache/camel/quarkus/component/messaging/it/JmsProducers.java
index c29064a..75d5da5 100644
--- 
a/integration-tests/messaging/src/main/java/org/apache/camel/quarkus/component/messaging/it/JmsProducers.java
+++ 
b/integration-tests/messaging/src/main/java/org/apache/camel/quarkus/component/messaging/it/JmsProducers.java
@@ -46,7 +46,12 @@ public class JmsProducers {
                 // Ignore and override the original queue name
                 return session.createQueue("destinationOverride");
             }
-            return session.createQueue(destinationName);
+
+            if (pubSubDomain) {
+                return session.createTopic(destinationName);
+            } else {
+                return session.createQueue(destinationName);
+            }
         };
     }
 
diff --git 
a/integration-tests/messaging/src/test/java/org/apache/camel/quarkus/component/messaging/it/JmsTest.java
 
b/integration-tests/messaging/src/test/java/org/apache/camel/quarkus/component/messaging/it/JmsTest.java
index a16905c..6df6eae 100644
--- 
a/integration-tests/messaging/src/test/java/org/apache/camel/quarkus/component/messaging/it/JmsTest.java
+++ 
b/integration-tests/messaging/src/test/java/org/apache/camel/quarkus/component/messaging/it/JmsTest.java
@@ -24,7 +24,6 @@ import io.quarkus.test.junit.DisabledOnNativeImage;
 import io.quarkus.test.junit.QuarkusTest;
 import io.restassured.RestAssured;
 import io.restassured.http.ContentType;
-import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.ValueSource;
@@ -126,7 +125,6 @@ class JmsTest {
     }
 
     @Test
-    @Disabled("https://github.com/apache/camel-quarkus/issues/2608";)
     public void testJmsTopic() {
         String message = "Camel JMS Topic Message";
         RestAssured.given()