You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by gi...@apache.org on 2020/11/17 01:28:56 UTC
[camel-kafka-connector] 09/09: Fixed incorrect formatting of Bucket
URL in Couchbase tests
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 f50dd54aa37ab1e75484dbdf976ab163b55b531f
Author: Otavio Rodolfo Piske <op...@redhat.com>
AuthorDate: Mon Nov 16 10:00:21 2020 +0100
Fixed incorrect formatting of Bucket URL in Couchbase tests
---
.../kafkaconnector/couchbase/sink/CamelCouchbasePropertyFactory.java | 4 ++--
.../camel/kafkaconnector/couchbase/sink/CamelSinkCouchbaseITCase.java | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/tests/itests-couchbase/src/test/java/org/apache/camel/kafkaconnector/couchbase/sink/CamelCouchbasePropertyFactory.java b/tests/itests-couchbase/src/test/java/org/apache/camel/kafkaconnector/couchbase/sink/CamelCouchbasePropertyFactory.java
index dd0e9d9..64d66aa 100644
--- a/tests/itests-couchbase/src/test/java/org/apache/camel/kafkaconnector/couchbase/sink/CamelCouchbasePropertyFactory.java
+++ b/tests/itests-couchbase/src/test/java/org/apache/camel/kafkaconnector/couchbase/sink/CamelCouchbasePropertyFactory.java
@@ -54,8 +54,8 @@ public class CamelCouchbasePropertyFactory extends SinkConnectorPropertyFactory<
return setProperty("camel.sink.endpoint.password", value);
}
- public EndpointUrlBuilder<CamelCouchbasePropertyFactory> withUrl(String protocol, String hostname, int port, String bucket) {
- String sinkUrl = String.format("couchbase:%s://%s:%d/%s", protocol, hostname, port, bucket);
+ public EndpointUrlBuilder<CamelCouchbasePropertyFactory> withUrl(String protocol, String hostname, int port) {
+ String sinkUrl = String.format("couchbase:%s://%s:%d", protocol, hostname, port);
return new EndpointUrlBuilder<>(this::withSinkUrl, sinkUrl);
}
diff --git a/tests/itests-couchbase/src/test/java/org/apache/camel/kafkaconnector/couchbase/sink/CamelSinkCouchbaseITCase.java b/tests/itests-couchbase/src/test/java/org/apache/camel/kafkaconnector/couchbase/sink/CamelSinkCouchbaseITCase.java
index 6c75920..a37b50d 100644
--- a/tests/itests-couchbase/src/test/java/org/apache/camel/kafkaconnector/couchbase/sink/CamelSinkCouchbaseITCase.java
+++ b/tests/itests-couchbase/src/test/java/org/apache/camel/kafkaconnector/couchbase/sink/CamelSinkCouchbaseITCase.java
@@ -184,13 +184,13 @@ public class CamelSinkCouchbaseITCase extends AbstractKafkaTest {
runTest(factory);
}
- @Disabled("Due to CAMEL-15789")
@Test
@Timeout(90)
public void testBasicSendReceiveUsingUrl() throws Exception {
ConnectorPropertyFactory factory = CamelCouchbasePropertyFactory.basic()
.withTopics(topic)
- .withUrl("http", service.getHostname(), service.getPort(), bucketName)
+ .withUrl("http", service.getHostname(), service.getPort())
+ .append("bucket", bucketName)
.append("username", service.getUsername())
.append("password", service.getPassword())
.buildUrl();