[camel-kafka-connector] 04/06: Avoid slashes on RabbitMQ component
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 210b54f9b84042c8feb5a7a99b09478ac2c2e253
Author: Otavio Rodolfo Piske
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 withUrl(String
exchangeName) {
-String sourceUrl = String.format("rabbitmq://%s", exchangeName);
+String sourceUrl = String.format("rabbitmq:%s", exchangeName);
return new EndpointUrlBuilder<>(this::withSinkUrl, sourceUrl);
}
[camel-kafka-connector] 04/06: Avoid slashes on RabbitMQ component
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 fe878ce05bcf8e1f7b3f780e0f70433b75eb6ffe
Author: Otavio Rodolfo Piske
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 withUrl(String
exchangeName) {
-String sourceUrl = String.format("rabbitmq://%s", exchangeName);
+String sourceUrl = String.format("rabbitmq:%s", exchangeName);
return new EndpointUrlBuilder<>(this::withSinkUrl, sourceUrl);
}
