You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ji...@apache.org on 2026/03/30 07:14:39 UTC

(camel-quarkus) 27/31: Fixed couchbase bacause of CAMEL-23218

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

jiriondrusek pushed a commit to branch camel-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git

commit 61dea5c45c8509f10af3c9f43552ca56cfbc9f5c
Author: Jiri Ondrusek <on...@gmail.com>
AuthorDate: Fri Mar 20 16:40:26 2026 +0100

    Fixed couchbase bacause of CAMEL-23218
---
 .../camel/quarkus/component/couchbase/it/CouchbaseResource.java   | 4 +++-
 .../quarkus/component/couchbase/it/CouchbaseTestResource.java     | 8 --------
 pom.xml                                                           | 2 +-
 3 files changed, 4 insertions(+), 10 deletions(-)

diff --git a/integration-tests-jvm/couchbase/src/main/java/org/apache/camel/quarkus/component/couchbase/it/CouchbaseResource.java b/integration-tests-jvm/couchbase/src/main/java/org/apache/camel/quarkus/component/couchbase/it/CouchbaseResource.java
index b19c2e2343..631f8ee2a5 100644
--- a/integration-tests-jvm/couchbase/src/main/java/org/apache/camel/quarkus/component/couchbase/it/CouchbaseResource.java
+++ b/integration-tests-jvm/couchbase/src/main/java/org/apache/camel/quarkus/component/couchbase/it/CouchbaseResource.java
@@ -90,7 +90,9 @@ public class CouchbaseResource {
     @Produces(MediaType.TEXT_PLAIN)
     public String poll() {
         LOG.infof("polling one document");
-        String endpoint = String.format("%s&designDocumentName=%s&viewName=%s&limit=1", connectionUri, bucketName, bucketName);
+        String statement = String.format("SELECT META().id AS __id, * FROM %s._default._default ORDER BY META().id LIMIT 1",
+                bucketName);
+        String endpoint = String.format("%s&statement=%s", connectionUri, statement);
         GetResult result = consumerTemplate.receiveBody(endpoint, timeout, GetResult.class);
         return result != null ? result.contentAs(String.class) : null;
     }
diff --git a/integration-tests-jvm/couchbase/src/test/java/org/apache/camel/quarkus/component/couchbase/it/CouchbaseTestResource.java b/integration-tests-jvm/couchbase/src/test/java/org/apache/camel/quarkus/component/couchbase/it/CouchbaseTestResource.java
index fb259ffe15..7824d1bab3 100644
--- a/integration-tests-jvm/couchbase/src/test/java/org/apache/camel/quarkus/component/couchbase/it/CouchbaseTestResource.java
+++ b/integration-tests-jvm/couchbase/src/test/java/org/apache/camel/quarkus/component/couchbase/it/CouchbaseTestResource.java
@@ -17,15 +17,11 @@
 package org.apache.camel.quarkus.component.couchbase.it;
 
 import java.time.Duration;
-import java.util.Collections;
 import java.util.Map;
 
 import com.couchbase.client.java.Cluster;
 import com.couchbase.client.java.manager.bucket.BucketSettings;
 import com.couchbase.client.java.manager.bucket.BucketType;
-import com.couchbase.client.java.manager.view.DesignDocument;
-import com.couchbase.client.java.manager.view.View;
-import com.couchbase.client.java.view.DesignDocumentNamespace;
 import io.quarkus.test.common.QuarkusTestResourceLifecycleManager;
 import org.apache.camel.util.CollectionHelper;
 import org.eclipse.microprofile.config.ConfigProvider;
@@ -106,10 +102,6 @@ public class CouchbaseTestResource implements QuarkusTestResourceLifecycleManage
                 BucketSettings.create(bucketName).bucketType(BucketType.COUCHBASE).flushEnabled(true));
 
         cluster.bucket(bucketName);
-        DesignDocument designDoc = new DesignDocument(
-                bucketName,
-                Collections.singletonMap(bucketName, new View("function (doc, meta) {  emit(meta.id, doc);}")));
-        cluster.bucket(bucketName).viewIndexes().upsertDesignDocument(designDoc, DesignDocumentNamespace.PRODUCTION);
         // wait for cluster
         cluster.bucket(bucketName).waitUntilReady(Duration.ofSeconds(30));
 
diff --git a/pom.xml b/pom.xml
index 1dd99dd79d..2985efe488 100644
--- a/pom.xml
+++ b/pom.xml
@@ -240,7 +240,7 @@
         <calculator-ws.container.image>quay.io/l2x6/calculator-ws:1.2</calculator-ws.container.image>
         <cassandra.container.image>mirror.gcr.io/cassandra:5.0.2</cassandra.container.image>
         <consul.container.image>mirror.gcr.io/hashicorp/consul:1.21</consul.container.image>
-        <couchbase.container.image>mirror.gcr.io/couchbase/server:7.6.2</couchbase.container.image>
+        <couchbase.container.image>mirror.gcr.io/couchbase/server:8.0.0</couchbase.container.image>
         <couchdb.container.image>mirror.gcr.io/couchdb:3.5.0</couchdb.container.image>
         <cyberark-conjur.container.image>mirror.gcr.io/cyberark/conjur:1.24.0</cyberark-conjur.container.image>
         <cyberark-conjur-cli.container.image>mirror.gcr.io/cyberark/conjur-cli:9</cyberark-conjur-cli.container.image>