[camel-kafka-connector] 07/17: Fixed incorrect formatting of Bucket URL in Couchbase tests

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit 8bb965453becbb36d29666be482de9e5cd8e9286
Author: Otavio Rodolfo Piske <opi...@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();