This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch camel-spring-boot-3.20.x in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
The following commit(s) were added to refs/heads/camel-spring-boot-3.20.x by this push: new 8390ae5f63b CAMEL-19133: camel-zookeeper - Serialize MetaData in camel-cloud service discovery problem. Thanks to geyipeng for patch. 8390ae5f63b is described below commit 8390ae5f63b9683ea32f449c44e304f429782342 Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Sat Mar 11 13:27:55 2023 +0100 CAMEL-19133: camel-zookeeper - Serialize MetaData in camel-cloud service discovery problem. Thanks to geyipeng for patch. --- .../springboot/cloud/ZooKeeperServiceRegistryTest.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/components-starter/camel-zookeeper-starter/src/test/java/org/apache/camel/component/zookeeper/springboot/cloud/ZooKeeperServiceRegistryTest.java b/components-starter/camel-zookeeper-starter/src/test/java/org/apache/camel/component/zookeeper/springboot/cloud/ZooKeeperServiceRegistryTest.java index 1103cb21fea..377ccd10290 100644 --- a/components-starter/camel-zookeeper-starter/src/test/java/org/apache/camel/component/zookeeper/springboot/cloud/ZooKeeperServiceRegistryTest.java +++ b/components-starter/camel-zookeeper-starter/src/test/java/org/apache/camel/component/zookeeper/springboot/cloud/ZooKeeperServiceRegistryTest.java @@ -23,7 +23,7 @@ import java.util.UUID; import org.apache.camel.CamelContext; import org.apache.camel.cloud.ServiceRegistry; -import org.apache.camel.component.zookeeper.cloud.ZooKeeperServiceRegistry; +import org.apache.camel.component.zookeeper.cloud.MetaData; import org.apache.camel.impl.cloud.DefaultServiceDefinition; import org.apache.camel.test.AvailablePortFinder; import org.apache.curator.framework.CuratorFramework; @@ -100,7 +100,7 @@ public class ZooKeeperServiceRegistryTest { .build() ); - final Collection<ServiceInstance<ZooKeeperServiceRegistry.MetaData>> services = zkClient.discovery().queryForInstances(SERVICE_NAME); + final Collection<ServiceInstance<MetaData>> services = zkClient.discovery().queryForInstances(SERVICE_NAME); assertThat(services).hasSize(1); assertThat(services).first().hasFieldOrPropertyWithValue("id", SERVICE_ID); @@ -130,17 +130,17 @@ public class ZooKeeperServiceRegistryTest { public static class ZooKeeperTestClient { private final CuratorFramework curator; - private final ServiceDiscovery<ZooKeeperServiceRegistry.MetaData> discovery; + private final ServiceDiscovery<MetaData> discovery; public ZooKeeperTestClient(String nodes) { curator = CuratorFrameworkFactory.builder() .connectString(nodes) .retryPolicy(new ExponentialBackoffRetry(1000, 3)) .build(); - discovery = ServiceDiscoveryBuilder.builder(ZooKeeperServiceRegistry.MetaData.class) + discovery = ServiceDiscoveryBuilder.builder(MetaData.class) .client(curator) .basePath(SERVICE_PATH) - .serializer(new JsonInstanceSerializer<>(ZooKeeperServiceRegistry.MetaData.class)) + .serializer(new JsonInstanceSerializer<>(MetaData.class)) .build(); } @@ -148,7 +148,7 @@ public class ZooKeeperServiceRegistryTest { return curator; } - public ServiceDiscovery<ZooKeeperServiceRegistry.MetaData> discovery() { + public ServiceDiscovery<MetaData> discovery() { return discovery; }