This is an automated email from the ASF dual-hosted git repository. apupier pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit b8507137f4790edd33ce192db8e3e832bbceb4e9 Author: Guillaume Nodet <[email protected]> AuthorDate: Tue Mar 10 16:53:52 2026 +0100 chore(camel-couchbase): fix tests for Couchbase 8.0.0 Couchbase 8.0.0 changed the default storage backend from CouchStore to Magma. Map/Reduce views only work with CouchStore, so explicitly set StorageBackend.COUCHSTORE when creating the test bucket. Co-Authored-By: Claude Opus 4.6 <[email protected]> --- .../component/couchbase/integration/CouchbaseIntegrationTestBase.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/CouchbaseIntegrationTestBase.java b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/CouchbaseIntegrationTestBase.java index ac1240e5df6e..d95cea520078 100644 --- a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/CouchbaseIntegrationTestBase.java +++ b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/CouchbaseIntegrationTestBase.java @@ -23,6 +23,7 @@ import java.util.Collections; 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.bucket.StorageBackend; import com.couchbase.client.java.manager.view.DesignDocument; import com.couchbase.client.java.manager.view.View; import com.couchbase.client.java.view.DesignDocumentNamespace; @@ -48,7 +49,8 @@ public class CouchbaseIntegrationTestBase extends CamelTestSupport { cluster = Cluster.connect(service.getConnectionString(), service.getUsername(), service.getPassword()); cluster.buckets().createBucket( - BucketSettings.create(bucketName).bucketType(BucketType.COUCHBASE).flushEnabled(true)); + BucketSettings.create(bucketName).bucketType(BucketType.COUCHBASE) + .storageBackend(StorageBackend.COUCHSTORE).flushEnabled(true)); cluster.bucket(bucketName); DesignDocument designDoc = new DesignDocument(
