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>