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 2015/10/29 17:21:53 UTC
[2/3] camel git commit: Fixed CS
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));
+ }
+ }
}