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"); }