[jboss-svn-commits] JBL Code SVN: r30471 - labs/jbossrules/trunk/drools-pipeline/drools-camel/src/test/java/org/drools/pipeline/camel.

[jboss-svn-commits at lists.jboss.org]

Author: mark.proctor at jboss.com
Date: 2009-12-03 22:44:23 -0500 (Thu, 03 Dec 2009)
New Revision: 30471

Modified:
   labs/jbossrules/trunk/drools-pipeline/drools-camel/src/test/java/org/drools/pipeline/camel/CamelPipelineTest.java
Log:
JBRULES-2347 Drools Pipeline integration with Camel
-Added refactored configure, to make it more compact

Modified: labs/jbossrules/trunk/drools-pipeline/drools-camel/src/test/java/org/drools/pipeline/camel/CamelPipelineTest.java
===================================================================
--- labs/jbossrules/trunk/drools-pipeline/drools-camel/src/test/java/org/drools/pipeline/camel/CamelPipelineTest.java	2009-12-04 03:39:13 UTC (rev 30470)
+++ labs/jbossrules/trunk/drools-pipeline/drools-camel/src/test/java/org/drools/pipeline/camel/CamelPipelineTest.java	2009-12-04 03:44:23 UTC (rev 30471)
@@ -295,16 +295,13 @@
 
     public void configure() {
         // START SNIPPET: example
-        from("direct:start").process(new ToXmlNodeTransformer()).to("direct:xstreamTransformer");
-
-        from("direct:xstreamTransformer").process(new CamelXStreamFromXmlVsmTransformer(xstreamStrategy)).to("direct:executor");
-        from("direct:executor").process(new BatchExecutorProcessor()).to("direct:xstreamTransformerResult");
-
-        from("direct:xstreamTransformerResult").process(new CamelXStreamToXmlVsmTransformer()).to("direct:finalResult");
-
-        from("direct:finalResult").process(new AssignResultProcessor()).to("direct:executeResult");
-
-        from("direct:executeResult").process(new ExecuteResultProcessor());
-
+        from("direct:start")
+            .process(new ToXmlNodeTransformer())
+            .process(new CamelXStreamFromXmlVsmTransformer(xstreamStrategy))
+            .process(new BatchExecutorProcessor())
+            .process(new CamelXStreamToXmlVsmTransformer())
+            .process(new AssignResultProcessor())
+            .process(new ExecuteResultProcessor());
+        // END SNIPPET: example
     }
 }