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 <anco...@gmail.com> Authored: Tue Jul 12 11:08:27 2016 +0200 Committer: Andrea Cosentino <anco...@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()); + } + } + }); } }
