You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2019/08/02 13:07:08 UTC
[camel] 03/04: CAMEL-13801 - Fixed CS for Camel-zookeeper
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 266fb3fad20b2d39ca57e5a53058e3b838822042
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Aug 2 15:06:04 2019 +0200
CAMEL-13801 - Fixed CS for Camel-zookeeper
---
...erServiceRegistrationWithServiceComponentTest.java | 19 ++++++-------------
1 file changed, 6 insertions(+), 13 deletions(-)
diff --git a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistrationWithServiceComponentTest.java b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistrationWithServiceComponentTest.java
index ca131f8..1bf1b55 100644
--- a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistrationWithServiceComponentTest.java
+++ b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cloud/ZooKeeperServiceRegistrationWithServiceComponentTest.java
@@ -19,6 +19,7 @@ package org.apache.camel.component.zookeeper.cloud;
import java.util.Collections;
import java.util.Map;
+import org.apache.camel.BindToRegistry;
import org.apache.camel.RoutesBuilder;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.service.ServiceComponent;
@@ -26,28 +27,20 @@ import org.apache.camel.impl.JndiRegistry;
public class ZooKeeperServiceRegistrationWithServiceComponentTest extends ZooKeeperServiceRegistrationTestBase {
+ @BindToRegistry("service")
+ private ServiceComponent service = new ServiceComponent();
+
protected Map<String, String> getMetadata() {
return Collections.singletonMap("service.type", "zookeeper");
}
@Override
- protected JndiRegistry createRegistry() throws Exception {
- JndiRegistry registry = super.createRegistry();
- registry.bind("service", new ServiceComponent());
-
- return registry;
- }
-
- @Override
protected RoutesBuilder createRouteBuilder() throws Exception {
return new RouteBuilder() {
@Override
public void configure() throws Exception {
- fromF("service:%s:jetty:http://0.0.0.0:%d/service/endpoint?service.type=zookeeper", SERVICE_NAME, SERVICE_PORT)
- .routeId(SERVICE_ID)
- .routeGroup(SERVICE_NAME)
- .noAutoStartup()
- .to("log:service-registry?level=INFO");
+ fromF("service:%s:jetty:http://0.0.0.0:%d/service/endpoint?service.type=zookeeper", SERVICE_NAME, SERVICE_PORT).routeId(SERVICE_ID).routeGroup(SERVICE_NAME)
+ .noAutoStartup().to("log:service-registry?level=INFO");
}
};
}