[camel] branch main updated: CAMEL-18608: fix tests of type ZooKeeperServiceRegistrationITBase (p2)

[nf...@apache.org]

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

nfilotto 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 75546bf155a CAMEL-18608: fix tests of type ZooKeeperServiceRegistrationITBase (p2)
75546bf155a is described below

commit 75546bf155a375eac688c301063a746bfae4172a
Author: Nicolas Filotto <nf...@talend.com>
AuthorDate: Mon Oct 17 10:49:49 2022 +0200

    CAMEL-18608: fix tests of type ZooKeeperServiceRegistrationITBase (p2)
---
 .../cloud/integration/ZooKeeperServiceRegistrationITBase.java          | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationITBase.java b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationITBase.java
index 75232769690..98fbb025004 100644
--- a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationITBase.java
+++ b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/integration/ZooKeeperServiceRegistrationITBase.java
@@ -124,8 +124,9 @@ public abstract class ZooKeeperServiceRegistrationITBase extends CamelTestSuppor
         context().getRouteController().startRoute(SERVICE_ID);
 
         // check that service has been registered
+        await().atMost(2, TimeUnit.MINUTES)
+                .untilAsserted(() -> assertEquals(1, discovery.queryForInstances(SERVICE_NAME).size()));
         Collection<ServiceInstance<ZooKeeperServiceRegistry.MetaData>> services = discovery.queryForInstances(SERVICE_NAME);
-        await().atMost(2, TimeUnit.MINUTES).untilAsserted(() -> assertEquals(1, services.size()));
 
         ServiceInstance<ZooKeeperServiceRegistry.MetaData> instance = services.iterator().next();
         assertEquals(SERVICE_PORT, (int) instance.getPort());