You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2021/01/11 15:06:28 UTC
[camel-kafka-connector] branch camel-master updated: Avoid slashes
on RabbitMQ component
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
The following commit(s) were added to refs/heads/camel-master by this push:
new d2d064c Avoid slashes on RabbitMQ component
d2d064c is described below
commit d2d064c347226c1fb0a3c9a3b74e901f389d8b29
Author: Otavio Rodolfo Piske <op...@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);
}