Fix apache#2608 to create destination correctly and re-enable the tes…

…t case
zhfeng · Jun 4, 2021 · 78d0858 · 78d0858
1 parent b5833d5
commit 78d0858
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/...messaging/src/main/java/org/apache/camel/quarkus/component/messaging/it/JmsProducers.java b/...messaging/src/main/java/org/apache/camel/quarkus/component/messaging/it/JmsProducers.java
@@ -46,7 +46,12 @@ public DestinationResolver customDestinationResolver() {
                 // 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/...ests/messaging/src/test/java/org/apache/camel/quarkus/component/messaging/it/JmsTest.java b/...ests/messaging/src/test/java/org/apache/camel/quarkus/component/messaging/it/JmsTest.java
@@ -24,7 +24,6 @@
 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 @@ public void testJmsMessageConverter() {
     }
 
     @Test
-    @Disabled("https://github.com/apache/camel-quarkus/issues/2608")
     public void testJmsTopic() {
         String message = "Camel JMS Topic Message";
         RestAssured.given()