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/03/03 16:58:08 UTC
[camel-kafka-connector] 05/07: Remove duplicate slashes (//) to
comply with recent netty URI changes on Camel (ref: CAMEL-16280)
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 3d96ebc214db50cb8d78d078b6309605b82a9309
Author: Otavio Rodolfo Piske <op...@redhat.com>
AuthorDate: Wed Mar 3 14:17:46 2021 +0100
Remove duplicate slashes (//) to comply with recent netty URI changes on Camel (ref: CAMEL-16280)
---
.../camel/kafkaconnector/syslog/sink/CamelSyslogPropertyFactory.java | 2 +-
.../camel/kafkaconnector/syslog/source/CamelSyslogPropertyFactory.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/tests/itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/sink/CamelSyslogPropertyFactory.java b/tests/itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/sink/CamelSyslogPropertyFactory.java
index 4d3ce24..5e41104 100644
--- a/tests/itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/sink/CamelSyslogPropertyFactory.java
+++ b/tests/itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/sink/CamelSyslogPropertyFactory.java
@@ -29,7 +29,7 @@ final class CamelSyslogPropertyFactory extends SinkConnectorPropertyFactory<Came
}
public CamelSyslogPropertyFactory withHost(String host) {
- return setProperty("camel.sink.path.host", "//" + host);
+ return setProperty("camel.sink.path.host", host);
}
public CamelSyslogPropertyFactory withPort(int port) {
diff --git a/tests/itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/source/CamelSyslogPropertyFactory.java b/tests/itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/source/CamelSyslogPropertyFactory.java
index 5e4cd2a..bf438fd 100644
--- a/tests/itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/source/CamelSyslogPropertyFactory.java
+++ b/tests/itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/source/CamelSyslogPropertyFactory.java
@@ -29,7 +29,7 @@ final class CamelSyslogPropertyFactory extends SourceConnectorPropertyFactory<Ca
}
public CamelSyslogPropertyFactory withHost(String host) {
- return setProperty("camel.source.path.host", "//" + host);
+ return setProperty("camel.source.path.host", host);
}
public CamelSyslogPropertyFactory withPort(int port) {