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 2016/07/12 09:21:37 UTC
[3/3] camel git commit: Fixed CS
Fixed CS
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/574cb0c6
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/574cb0c6
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/574cb0c6
Branch: refs/heads/master
Commit: 574cb0c67d8d76f333acb3f892aebdd98e32cd49
Parents: 0c241dc
Author: Andrea Cosentino <an...@gmail.com>
Authored: Tue Jul 12 11:08:27 2016 +0200
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Tue Jul 12 11:08:27 2016 +0200
----------------------------------------------------------------------
.../example/cdi/kubernetes/Application.java | 27 ++++++++++----------
1 file changed, 13 insertions(+), 14 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/574cb0c6/examples/camel-example-cdi-kubernetes/src/main/java/org/apache/camel/example/cdi/kubernetes/Application.java
----------------------------------------------------------------------
diff --git a/examples/camel-example-cdi-kubernetes/src/main/java/org/apache/camel/example/cdi/kubernetes/Application.java b/examples/camel-example-cdi-kubernetes/src/main/java/org/apache/camel/example/cdi/kubernetes/Application.java
index 16cd57a..db25c64 100644
--- a/examples/camel-example-cdi-kubernetes/src/main/java/org/apache/camel/example/cdi/kubernetes/Application.java
+++ b/examples/camel-example-cdi-kubernetes/src/main/java/org/apache/camel/example/cdi/kubernetes/Application.java
@@ -24,6 +24,8 @@ import javax.enterprise.context.ApplicationScoped;
import javax.enterprise.inject.Produces;
import javax.inject.Named;
+import io.fabric8.kubernetes.api.model.Pod;
+
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.builder.RouteBuilder;
@@ -33,8 +35,6 @@ import org.apache.camel.component.properties.PropertiesComponent;
import org.apache.camel.component.properties.PropertiesParser;
import org.apache.deltaspike.core.api.config.ConfigResolver;
-import io.fabric8.kubernetes.api.model.Pod;
-
class Application {
@ContextName("camel-example-kubernetes-cdi")
@@ -46,19 +46,18 @@ class Application {
from("timer:stream?repeatCount=3")
.to("kubernetes://{{kubernetes-master-url}}?oauthToken={{kubernetes-oauth-token}}&category=pods&operation=listPods")
.process(new Processor() {
-
- @Override
- public void process(Exchange exchange) throws Exception {
- List<Pod> list = exchange.getIn().getBody(List.class);
- System.out.println("We currently have " + list.size() + " pods");
- Iterator<Pod> it = list.iterator();
+
+ @Override
+ public void process(Exchange exchange) throws Exception {
+ List<Pod> list = exchange.getIn().getBody(List.class);
+ System.out.println("We currently have " + list.size() + " pods");
+ Iterator<Pod> it = list.iterator();
while (it.hasNext()) {
- Pod pod = it.next();
- System.out.println("Pod name " + pod.getMetadata().getName() + " with status " + pod.getStatus().getPhase());
- }
-
- }
- });
+ Pod pod = it.next();
+ System.out.println("Pod name " + pod.getMetadata().getName() + " with status " + pod.getStatus().getPhase());
+ }
+ }
+ });
}
}