http://git-wip-us.apache.org/repos/asf/camel/blob/6cefe5ee/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesReplicationControllersConsumerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesReplicationControllersConsumerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesReplicationControllersConsumerTest.java index e9df6dc..2c6cf6d 100644 --- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesReplicationControllersConsumerTest.java +++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesReplicationControllersConsumerTest.java @@ -16,19 +16,13 @@ */ package org.apache.camel.component.kubernetes.consumer; +import java.util.HashMap; +import java.util.Map; + import io.fabric8.kubernetes.api.model.EditablePodTemplateSpec; -import io.fabric8.kubernetes.api.model.IntOrString; import io.fabric8.kubernetes.api.model.PodTemplateSpecBuilder; import io.fabric8.kubernetes.api.model.ReplicationController; import io.fabric8.kubernetes.api.model.ReplicationControllerSpec; -import io.fabric8.kubernetes.api.model.Service; -import io.fabric8.kubernetes.api.model.ServicePort; -import io.fabric8.kubernetes.api.model.ServiceSpec; - -import java.util.ArrayList; -import java.util.HashMap; -import java.util.List; -import java.util.Map; import org.apache.camel.EndpointInject; import org.apache.camel.Exchange; @@ -38,128 +32,100 @@ import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.kubernetes.KubernetesConstants; import org.apache.camel.component.kubernetes.KubernetesTestSupport; import org.apache.camel.component.mock.MockEndpoint; -import org.apache.camel.test.junit4.CamelTestSupport; import org.apache.camel.util.ObjectHelper; import org.junit.Test; -public class KubernetesReplicationControllersConsumerTest extends - KubernetesTestSupport { - - @EndpointInject(uri = "mock:result") - protected MockEndpoint mockResultEndpoint; - - @Test - public void createAndDeleteReplicationController() throws Exception { - if (ObjectHelper.isEmpty(authToken)) { - return; - } - - mockResultEndpoint - .expectedHeaderValuesReceivedInAnyOrder( - KubernetesConstants.KUBERNETES_EVENT_ACTION, "ADDED", - "DELETED", "MODIFIED", "MODIFIED", "MODIFIED"); - Exchange ex = template.request("direct:createReplicationController", - new Processor() { - - @Override - public void process(Exchange exchange) throws Exception { - exchange.getIn().setHeader( - KubernetesConstants.KUBERNETES_NAMESPACE_NAME, - "default"); - exchange.getIn() - .setHeader( - KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLER_NAME, - "test"); - Map<String, String> labels = new HashMap<String, String>(); - labels.put("this", "rocks"); - exchange.getIn() - .setHeader( - KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLERS_LABELS, - labels); - ReplicationControllerSpec rcSpec = new ReplicationControllerSpec(); - rcSpec.setReplicas(2); - PodTemplateSpecBuilder builder = new PodTemplateSpecBuilder(); - EditablePodTemplateSpec t = builder.withNewMetadata() - .withName("nginx-template") - .addToLabels("server", "nginx").endMetadata() - .withNewSpec().addNewContainer() - .withName("wildfly").withImage("jboss/wildfly") - .addNewPort().withContainerPort(80).endPort() - .endContainer().endSpec().build(); - rcSpec.setTemplate(t); - Map<String, String> selectorMap = new HashMap<String, String>(); - selectorMap.put("server", "nginx"); - rcSpec.setSelector(selectorMap); - exchange.getIn() - .setHeader( - KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLER_SPEC, - rcSpec); - } - }); - - ReplicationController rc = ex.getOut().getBody( - ReplicationController.class); +public class KubernetesReplicationControllersConsumerTest extends KubernetesTestSupport { + + @EndpointInject(uri = "mock:result") + protected MockEndpoint mockResultEndpoint; + + @Test + public void createAndDeleteReplicationController() throws Exception { + if (ObjectHelper.isEmpty(authToken)) { + return; + } + + mockResultEndpoint.expectedHeaderValuesReceivedInAnyOrder(KubernetesConstants.KUBERNETES_EVENT_ACTION, "ADDED", + "DELETED", "MODIFIED", "MODIFIED", "MODIFIED"); + Exchange ex = template.request("direct:createReplicationController", new Processor() { + + @Override + public void process(Exchange exchange) throws Exception { + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, "default"); + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLER_NAME, "test"); + Map<String, String> labels = new HashMap<String, String>(); + labels.put("this", "rocks"); + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLERS_LABELS, labels); + ReplicationControllerSpec rcSpec = new ReplicationControllerSpec(); + rcSpec.setReplicas(2); + PodTemplateSpecBuilder builder = new PodTemplateSpecBuilder(); + EditablePodTemplateSpec t = builder.withNewMetadata().withName("nginx-template") + .addToLabels("server", "nginx").endMetadata().withNewSpec().addNewContainer() + .withName("wildfly").withImage("jboss/wildfly").addNewPort().withContainerPort(80).endPort() + .endContainer().endSpec().build(); + rcSpec.setTemplate(t); + Map<String, String> selectorMap = new HashMap<String, String>(); + selectorMap.put("server", "nginx"); + rcSpec.setSelector(selectorMap); + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLER_SPEC, rcSpec); + } + }); + + ReplicationController rc = ex.getOut().getBody(ReplicationController.class); assertEquals(rc.getMetadata().getName(), "test"); - ex = template.request("direct:deleteReplicationController", - new Processor() { - - @Override - public void process(Exchange exchange) throws Exception { - exchange.getIn().setHeader( - KubernetesConstants.KUBERNETES_NAMESPACE_NAME, - "default"); - exchange.getIn() - .setHeader( - KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLER_NAME, - "test"); - } - }); + ex = template.request("direct:deleteReplicationController", new Processor() { + + @Override + public void process(Exchange exchange) throws Exception { + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, "default"); + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_REPLICATION_CONTROLLER_NAME, "test"); + } + }); boolean rcDeleted = ex.getOut().getBody(Boolean.class); assertTrue(rcDeleted); - Thread.sleep(1 * 1000); - - mockResultEndpoint.assertIsSatisfied(); - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - from("direct:list") - .toF("kubernetes://%s?oauthToken=%s&category=replicationControllers&operation=listReplicationControllers", - host, authToken); - from("direct:listByLabels") - .toF("kubernetes://%s?oauthToken=%s&category=replicationControllers&operation=listReplicationControllersByLabels", - host, authToken); - from("direct:getReplicationController") - .toF("kubernetes://%s?oauthToken=%s&category=replicationControllers&operation=getReplicationController", - host, authToken); - from("direct:createReplicationController") - .toF("kubernetes://%s?oauthToken=%s&category=replicationControllers&operation=createReplicationController", - host, authToken); - from("direct:deleteReplicationController") - .toF("kubernetes://%s?oauthToken=%s&category=replicationControllers&operation=deleteReplicationController", - host, authToken); - fromF( - "kubernetes://%s?oauthToken=%s&category=replicationControllers", - host, authToken).process(new KubernertesProcessor()) - .to(mockResultEndpoint); - } - }; - } - - public class KubernertesProcessor implements Processor { - @Override - public void process(Exchange exchange) throws Exception { - Message in = exchange.getIn(); - log.info("Got event with body: " + in.getBody() + " and action " - + in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION)); - } - } + Thread.sleep(1 * 1000); + + mockResultEndpoint.assertIsSatisfied(); + } + + @Override + protected RouteBuilder createRouteBuilder() throws Exception { + return new RouteBuilder() { + @Override + public void configure() throws Exception { + from("direct:list").toF( + "kubernetes://%s?oauthToken=%s&category=replicationControllers&operation=listReplicationControllers", + host, authToken); + from("direct:listByLabels").toF( + "kubernetes://%s?oauthToken=%s&category=replicationControllers&operation=listReplicationControllersByLabels", + host, authToken); + from("direct:getReplicationController").toF( + "kubernetes://%s?oauthToken=%s&category=replicationControllers&operation=getReplicationController", + host, authToken); + from("direct:createReplicationController").toF( + "kubernetes://%s?oauthToken=%s&category=replicationControllers&operation=createReplicationController", + host, authToken); + from("direct:deleteReplicationController").toF( + "kubernetes://%s?oauthToken=%s&category=replicationControllers&operation=deleteReplicationController", + host, authToken); + fromF("kubernetes://%s?oauthToken=%s&category=replicationControllers", host, authToken) + .process(new KubernertesProcessor()).to(mockResultEndpoint); + } + }; + } + + public class KubernertesProcessor implements Processor { + @Override + public void process(Exchange exchange) throws Exception { + Message in = exchange.getIn(); + log.info("Got event with body: " + in.getBody() + " and action " + + in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION)); + } + } }
http://git-wip-us.apache.org/repos/asf/camel/blob/6cefe5ee/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesSecretsConsumerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesSecretsConsumerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesSecretsConsumerTest.java index e19ce67..1c40f49 100644 --- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesSecretsConsumerTest.java +++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesSecretsConsumerTest.java @@ -16,12 +16,14 @@ */ package org.apache.camel.component.kubernetes.consumer; -import io.fabric8.kubernetes.api.model.ObjectMeta; -import io.fabric8.kubernetes.api.model.Secret; - import java.util.HashMap; import java.util.Map; +import com.ning.http.util.Base64; + +import io.fabric8.kubernetes.api.model.ObjectMeta; +import io.fabric8.kubernetes.api.model.Secret; + import org.apache.camel.EndpointInject; import org.apache.camel.Exchange; import org.apache.camel.Message; @@ -30,39 +32,31 @@ import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.kubernetes.KubernetesConstants; import org.apache.camel.component.kubernetes.KubernetesTestSupport; import org.apache.camel.component.mock.MockEndpoint; -import org.apache.camel.test.junit4.CamelTestSupport; import org.apache.camel.util.ObjectHelper; import org.junit.Test; -import com.ning.http.util.Base64; - public class KubernetesSecretsConsumerTest extends KubernetesTestSupport { - @EndpointInject(uri = "mock:result") - protected MockEndpoint mockResultEndpoint; + @EndpointInject(uri = "mock:result") + protected MockEndpoint mockResultEndpoint; - @Test - public void createAndDeleteSecrets() throws Exception { - if (ObjectHelper.isEmpty(authToken)) { - return; - } + @Test + public void createAndDeleteSecrets() throws Exception { + if (ObjectHelper.isEmpty(authToken)) { + return; + } - mockResultEndpoint.expectedHeaderValuesReceivedInAnyOrder( - KubernetesConstants.KUBERNETES_EVENT_ACTION, "ADDED", - "DELETED"); - Exchange ex = template.request("direct:create", new Processor() { + mockResultEndpoint.expectedHeaderValuesReceivedInAnyOrder(KubernetesConstants.KUBERNETES_EVENT_ACTION, "ADDED", + "DELETED"); + Exchange ex = template.request("direct:create", new Processor() { @Override public void process(Exchange exchange) throws Exception { - exchange.getIn().setHeader( - KubernetesConstants.KUBERNETES_NAMESPACE_NAME, - "default"); - exchange.getIn().setHeader( - KubernetesConstants.KUBERNETES_SECRET_NAME, "test"); + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, "default"); + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_SECRET_NAME, "test"); Map<String, String> labels = new HashMap<String, String>(); labels.put("this", "rocks"); - exchange.getIn().setHeader( - KubernetesConstants.KUBERNETES_SECRETS_LABELS, labels); + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_SECRETS_LABELS, labels); Secret s = new Secret(); s.setKind("Secret"); Map<String, String> mp = new HashMap<String, String>(); @@ -73,8 +67,7 @@ public class KubernetesSecretsConsumerTest extends KubernetesTestSupport { ObjectMeta meta = new ObjectMeta(); meta.setName("test"); s.setMetadata(meta); - exchange.getIn().setHeader( - KubernetesConstants.KUBERNETES_SECRET, s); + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_SECRET, s); } }); @@ -86,11 +79,8 @@ public class KubernetesSecretsConsumerTest extends KubernetesTestSupport { @Override public void process(Exchange exchange) throws Exception { - exchange.getIn().setHeader( - KubernetesConstants.KUBERNETES_NAMESPACE_NAME, - "default"); - exchange.getIn().setHeader( - KubernetesConstants.KUBERNETES_SECRET_NAME, "test"); + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, "default"); + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_SECRET_NAME, "test"); } }); @@ -98,44 +88,39 @@ public class KubernetesSecretsConsumerTest extends KubernetesTestSupport { assertTrue(secDeleted); - Thread.sleep(1 * 1000); - - mockResultEndpoint.assertIsSatisfied(); - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - from("direct:list") - .toF("kubernetes://%s?oauthToken=%s&category=secrets&operation=listSecrets", - host, authToken); - from("direct:listByLabels") - .toF("kubernetes://%s?oauthToken=%s&category=secrets&operation=listSecretsByLabels", - host, authToken); - from("direct:get") - .toF("kubernetes://%s?oauthToken=%s&category=secrets&operation=getSecret", - host, authToken); - from("direct:create") - .toF("kubernetes://%s?oauthToken=%s&category=secrets&operation=createSecret", - host, authToken); - from("direct:delete") - .toF("kubernetes://%s?oauthToken=%s&category=secrets&operation=deleteSecret", - host, authToken); - fromF("kubernetes://%s?oauthToken=%s&category=secrets", host, - authToken).process(new KubernertesProcessor()).to( - mockResultEndpoint); - } - }; - } - - public class KubernertesProcessor implements Processor { - @Override - public void process(Exchange exchange) throws Exception { - Message in = exchange.getIn(); - log.info("Got event with body: " + in.getBody() + " and action " - + in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION)); - } - } + Thread.sleep(1 * 1000); + + mockResultEndpoint.assertIsSatisfied(); + } + + @Override + protected RouteBuilder createRouteBuilder() throws Exception { + return new RouteBuilder() { + @Override + public void configure() throws Exception { + from("direct:list").toF("kubernetes://%s?oauthToken=%s&category=secrets&operation=listSecrets", host, + authToken); + from("direct:listByLabels").toF( + "kubernetes://%s?oauthToken=%s&category=secrets&operation=listSecretsByLabels", host, + authToken); + from("direct:get").toF("kubernetes://%s?oauthToken=%s&category=secrets&operation=getSecret", host, + authToken); + from("direct:create").toF("kubernetes://%s?oauthToken=%s&category=secrets&operation=createSecret", host, + authToken); + from("direct:delete").toF("kubernetes://%s?oauthToken=%s&category=secrets&operation=deleteSecret", host, + authToken); + fromF("kubernetes://%s?oauthToken=%s&category=secrets", host, authToken) + .process(new KubernertesProcessor()).to(mockResultEndpoint); + } + }; + } + + public class KubernertesProcessor implements Processor { + @Override + public void process(Exchange exchange) throws Exception { + Message in = exchange.getIn(); + log.info("Got event with body: " + in.getBody() + " and action " + + in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION)); + } + } } http://git-wip-us.apache.org/repos/asf/camel/blob/6cefe5ee/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesServicesConsumerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesServicesConsumerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesServicesConsumerTest.java index 098069e..ac2bb76 100644 --- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesServicesConsumerTest.java +++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/consumer/KubernetesServicesConsumerTest.java @@ -16,16 +16,16 @@ */ package org.apache.camel.component.kubernetes.consumer; -import io.fabric8.kubernetes.api.model.IntOrString; -import io.fabric8.kubernetes.api.model.Service; -import io.fabric8.kubernetes.api.model.ServicePort; -import io.fabric8.kubernetes.api.model.ServiceSpec; - import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; +import io.fabric8.kubernetes.api.model.IntOrString; +import io.fabric8.kubernetes.api.model.Service; +import io.fabric8.kubernetes.api.model.ServicePort; +import io.fabric8.kubernetes.api.model.ServiceSpec; + import org.apache.camel.EndpointInject; import org.apache.camel.Exchange; import org.apache.camel.Message; @@ -34,112 +34,97 @@ import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.kubernetes.KubernetesConstants; import org.apache.camel.component.kubernetes.KubernetesTestSupport; import org.apache.camel.component.mock.MockEndpoint; -import org.apache.camel.test.junit4.CamelTestSupport; import org.apache.camel.util.ObjectHelper; import org.junit.Test; public class KubernetesServicesConsumerTest extends KubernetesTestSupport { - + @EndpointInject(uri = "mock:result") protected MockEndpoint mockResultEndpoint; - @Test - public void createAndDeleteService() throws Exception { - if (ObjectHelper.isEmpty(authToken)) { - return; - } - + @Test + public void createAndDeleteService() throws Exception { + if (ObjectHelper.isEmpty(authToken)) { + return; + } + mockResultEndpoint.expectedMessageCount(2); - mockResultEndpoint.expectedHeaderValuesReceivedInAnyOrder(KubernetesConstants.KUBERNETES_EVENT_ACTION, "ADDED", "DELETED"); - Exchange ex = template.request("direct:createService", new Processor() { - - @Override - public void process(Exchange exchange) throws Exception { - exchange.getIn().setHeader( - KubernetesConstants.KUBERNETES_NAMESPACE_NAME, - "default"); - exchange.getIn().setHeader( - KubernetesConstants.KUBERNETES_SERVICE_NAME, "test"); - Map<String, String> labels = new HashMap<String, String>(); - labels.put("this", "rocks"); - exchange.getIn().setHeader( - KubernetesConstants.KUBERNETES_SERVICE_LABELS, labels); - ServiceSpec serviceSpec = new ServiceSpec(); - List<ServicePort> lsp = new ArrayList<ServicePort>(); - ServicePort sp = new ServicePort(); - sp.setPort(8080); - sp.setTargetPort(new IntOrString(8080)); - sp.setProtocol("TCP"); - lsp.add(sp); - serviceSpec.setPorts(lsp); - Map<String, String> selectorMap = new HashMap<String, String>(); - selectorMap.put("containter", "test"); - serviceSpec.setSelector(selectorMap); - exchange.getIn().setHeader( - KubernetesConstants.KUBERNETES_SERVICE_SPEC, - serviceSpec); - } - }); - - Service serv = ex.getOut().getBody(Service.class); - - assertEquals(serv.getMetadata().getName(), "test"); - - ex = template.request("direct:deleteService", new Processor() { - - @Override - public void process(Exchange exchange) throws Exception { - exchange.getIn().setHeader( - KubernetesConstants.KUBERNETES_NAMESPACE_NAME, - "default"); - exchange.getIn().setHeader( - KubernetesConstants.KUBERNETES_SERVICE_NAME, "test"); - } - }); - - boolean servDeleted = ex.getOut().getBody(Boolean.class); - - assertTrue(servDeleted); - - Thread.sleep(1*1000); + mockResultEndpoint.expectedHeaderValuesReceivedInAnyOrder(KubernetesConstants.KUBERNETES_EVENT_ACTION, "ADDED", + "DELETED"); + Exchange ex = template.request("direct:createService", new Processor() { + + @Override + public void process(Exchange exchange) throws Exception { + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, "default"); + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_SERVICE_NAME, "test"); + Map<String, String> labels = new HashMap<String, String>(); + labels.put("this", "rocks"); + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_SERVICE_LABELS, labels); + ServiceSpec serviceSpec = new ServiceSpec(); + List<ServicePort> lsp = new ArrayList<ServicePort>(); + ServicePort sp = new ServicePort(); + sp.setPort(8080); + sp.setTargetPort(new IntOrString(8080)); + sp.setProtocol("TCP"); + lsp.add(sp); + serviceSpec.setPorts(lsp); + Map<String, String> selectorMap = new HashMap<String, String>(); + selectorMap.put("containter", "test"); + serviceSpec.setSelector(selectorMap); + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_SERVICE_SPEC, serviceSpec); + } + }); + + Service serv = ex.getOut().getBody(Service.class); + + assertEquals(serv.getMetadata().getName(), "test"); + + ex = template.request("direct:deleteService", new Processor() { + + @Override + public void process(Exchange exchange) throws Exception { + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, "default"); + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_SERVICE_NAME, "test"); + } + }); + + boolean servDeleted = ex.getOut().getBody(Boolean.class); + + assertTrue(servDeleted); + + Thread.sleep(1 * 1000); mockResultEndpoint.assertIsSatisfied(); - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - from("direct:list") - .toF("kubernetes://%s?oauthToken=%s&category=services&operation=listServices", - host, authToken); - from("direct:listByLabels") - .toF("kubernetes://%s?oauthToken=%s&category=services&operation=listServicesByLabels", - host, authToken); - from("direct:getServices") - .toF("kubernetes://%s?oauthToken=%s&category=services&operation=getService", - host, authToken); - from("direct:createService") - .toF("kubernetes://%s?oauthToken=%s&category=services&operation=createService", - host, authToken); - from("direct:deleteService") - .toF("kubernetes://%s?oauthToken=%s&category=services&operation=deleteService", + } + + @Override + protected RouteBuilder createRouteBuilder() throws Exception { + return new RouteBuilder() { + @Override + public void configure() throws Exception { + from("direct:list").toF("kubernetes://%s?oauthToken=%s&category=services&operation=listServices", host, + authToken); + from("direct:listByLabels").toF( + "kubernetes://%s?oauthToken=%s&category=services&operation=listServicesByLabels", host, + authToken); + from("direct:getServices").toF("kubernetes://%s?oauthToken=%s&category=services&operation=getService", host, authToken); - fromF("kubernetes://%s?oauthToken=%s&category=services", - host, authToken) - .process(new KubernertesProcessor()) - .to(mockResultEndpoint); - } - }; - } - - public class KubernertesProcessor implements Processor { - @Override - public void process(Exchange exchange) throws Exception { - Message in = exchange.getIn(); - log.info("Got event with body: " + in.getBody() + " and action " - + in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION)); - } - } + from("direct:createService").toF( + "kubernetes://%s?oauthToken=%s&category=services&operation=createService", host, authToken); + from("direct:deleteService").toF( + "kubernetes://%s?oauthToken=%s&category=services&operation=deleteService", host, authToken); + fromF("kubernetes://%s?oauthToken=%s&category=services", host, authToken) + .process(new KubernertesProcessor()).to(mockResultEndpoint); + } + }; + } + + public class KubernertesProcessor implements Processor { + @Override + public void process(Exchange exchange) throws Exception { + Message in = exchange.getIn(); + log.info("Got event with body: " + in.getBody() + " and action " + + in.getHeader(KubernetesConstants.KUBERNETES_EVENT_ACTION)); + } + } }
