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

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

commit b7c040bc7a6be6a686f571f3104bb6d86243ea6a
Author: Otavio Rodolfo Piske <opi...@redhat.com>
AuthorDate: Thu Feb 4 08:59:54 2021 +0100

    Fix error message check for SJMS2 startup on error test
---
 .../camel/kafkaconnector/sjms2/sink/CamelSinkJMSStartupITCase.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/sink/CamelSinkJMSStartupITCase.java
 
b/tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/sink/CamelSinkJMSStartupITCase.java
index f2dac55..735db4b 100644
--- 
a/tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/sink/CamelSinkJMSStartupITCase.java
+++ 
b/tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/sink/CamelSinkJMSStartupITCase.java
@@ -52,7 +52,7 @@ public class CamelSinkJMSStartupITCase extends 
AbstractKafkaTest {
         Properties properties = new Properties();
 
         properties.put("camel.component.sjms2.connection-factory", 
"#class:org.apache.qpid.jms.JmsConnectionFactory");
-        properties.put("camel.component.sjms2.connection-factory.remoteURI", 
"tcp://invalid");
+        properties.put("camel.component.sjms2.connection-factory.remoteURI", 
"amqp://invalid");
 
         return properties;
     }
@@ -100,7 +100,7 @@ public class CamelSinkJMSStartupITCase extends 
AbstractKafkaTest {
         assertFalse(running, "The connector should be in a failed state");
 
         LOG.trace(trace);
-        assertTrue(trace.contains("Failed to resolve endpoint"),
+        assertTrue(trace.contains("Name or service not known"),
                 "Trace should contain a Camel error message");
     }
 

Reply via email to