[camel] branch main updated: Do wait for started before running the test

[or...@apache.org]

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

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


The following commit(s) were added to refs/heads/main by this push:
     new 881588fc809 Do wait for started before running the test
881588fc809 is described below

commit 881588fc809904e38c07d024cc2bffe90d0e5d61
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Mon Aug 29 11:28:16 2022 +0200

    Do wait for started before running the test
---
 .../couchbase/integration/CouchbaseIntegrationTestBase.java          | 5 +++++
 1 file changed, 5 insertions(+)

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 f0b5c5bad1c..27d021984c9 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
@@ -33,6 +33,7 @@ import org.apache.camel.test.infra.couchbase.services.CouchbaseServiceFactory;
 import org.apache.camel.test.junit5.CamelTestSupport;
 import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.extension.RegisterExtension;
 
 public class CouchbaseIntegrationTestBase extends CamelTestSupport {
@@ -55,6 +56,10 @@ public class CouchbaseIntegrationTestBase extends CamelTestSupport {
                 bucketName,
                 Collections.singletonMap(bucketName, new View("function (doc, meta) {  emit(meta.id, doc);}")));
         cluster.bucket(bucketName).viewIndexes().upsertDesignDocument(designDoc, DesignDocumentNamespace.PRODUCTION);
+    }
+
+    @BeforeEach
+    public void waitForStarted() {
         cluster.bucket(bucketName).waitUntilReady(Duration.ofSeconds(30));
     }