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/09/17 08:25:29 UTC
[camel] 02/03: Camel-Kubernetes: Fixed CS
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch camel-2.x
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 83524f460788e2aa8f0ec17463ae4d49c74e923d
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Sep 17 09:53:53 2019 +0200
Camel-Kubernetes: Fixed CS
---
.../component/kubernetes/nodes/KubernetesNodesProducer.java | 4 ++--
.../kubernetes/producer/KubernetesNodesProducerTest.java | 9 ++++-----
2 files changed, 6 insertions(+), 7 deletions(-)
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesProducer.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesProducer.java
index 0e10b0c..73113d3 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesProducer.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesProducer.java
@@ -75,7 +75,7 @@ public class KubernetesNodesProducer extends DefaultProducer {
case KubernetesOperations.GET_NODE_OPERATION:
doGetNode(exchange, operation);
break;
-
+
case KubernetesOperations.CREATE_NODE_OPERATION:
doCreateNode(exchange, operation);
break;
@@ -117,7 +117,7 @@ public class KubernetesNodesProducer extends DefaultProducer {
MessageHelper.copyHeaders(exchange.getIn(), exchange.getOut(), true);
exchange.getOut().setBody(node);
}
-
+
protected void doCreateNode(Exchange exchange, String operation) throws Exception {
Node node = null;
String nodeName = exchange.getIn().getHeader(KubernetesConstants.KUBERNETES_NODE_NAME, String.class);
diff --git a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesNodesProducerTest.java b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesNodesProducerTest.java
index a5acf1a..abff2fd 100644
--- a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesNodesProducerTest.java
+++ b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/producer/KubernetesNodesProducerTest.java
@@ -81,13 +81,12 @@ public class KubernetesNodesProducerTest extends KubernetesTestSupport {
assertEquals(3, result.size());
}
-
+
@Test
public void createNodeTest() throws Exception {
- ObjectMeta meta = new ObjectMeta();
- meta.setName("test");
- server.expect().withPath("/api/v1/nodes")
- .andReturn(200, new NodeBuilder().withMetadata(meta).build()).once();
+ ObjectMeta meta = new ObjectMeta();
+ meta.setName("test");
+ server.expect().withPath("/api/v1/nodes").andReturn(200, new NodeBuilder().withMetadata(meta).build()).once();
Exchange ex = template.request("direct:createNode", new Processor() {
@Override