This is an automated email from the ASF dual-hosted git repository. github-bot pushed a commit to branch camel-master in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit b6d81299384d80ade2693de51256c24228e5bf54 Author: Otavio Rodolfo Piske <opi...@redhat.com> AuthorDate: Mon Jan 11 14:35:07 2021 +0100 Avoid slashes on RabbitMQ component --- .../kafkaconnector/rabbitmq/sink/CamelRabbitMQPropertyFactory.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tests/itests-rabbitmq/src/test/java/org/apache/camel/kafkaconnector/rabbitmq/sink/CamelRabbitMQPropertyFactory.java b/tests/itests-rabbitmq/src/test/java/org/apache/camel/kafkaconnector/rabbitmq/sink/CamelRabbitMQPropertyFactory.java index 0c8e467..16c667b 100644 --- a/tests/itests-rabbitmq/src/test/java/org/apache/camel/kafkaconnector/rabbitmq/sink/CamelRabbitMQPropertyFactory.java +++ b/tests/itests-rabbitmq/src/test/java/org/apache/camel/kafkaconnector/rabbitmq/sink/CamelRabbitMQPropertyFactory.java @@ -58,7 +58,7 @@ public class CamelRabbitMQPropertyFactory extends SinkConnectorPropertyFactory<C } public EndpointUrlBuilder<CamelRabbitMQPropertyFactory> withUrl(String exchangeName) { - String sourceUrl = String.format("rabbitmq://%s", exchangeName); + String sourceUrl = String.format("rabbitmq:%s", exchangeName); return new EndpointUrlBuilder<>(this::withSinkUrl, sourceUrl); }