svn commit: r902598 - /camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FromFileMulticastToFilesTest.java

[davsclaus]

Author: davsclaus
Date: Sun Jan 24 16:36:54 2010
New Revision: 902598

URL: http://svn.apache.org/viewvc?rev=902598&view=rev
Log:
CAMEL-2395: Also test with parallel.

Modified:
    
camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FromFileMulticastToFilesTest.java

Modified: 
camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FromFileMulticastToFilesTest.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FromFileMulticastToFilesTest.java?rev=902598&r1=902597&r2=902598&view=diff
==============================================================================
--- 
camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FromFileMulticastToFilesTest.java
 (original)
+++ 
camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FromFileMulticastToFilesTest.java
 Sun Jan 24 16:36:54 2010
@@ -33,6 +33,27 @@
     }
 
     public void testFromFileMulticastToFiles() throws Exception {
+        context.addRoutes(new RouteBuilder() {
+            @Override
+            public void configure() throws Exception {
+                from("file://target/multicast")
+                    .multicast()
+                        .pipeline()
+                            .transform(body().prepend("HEADER:"))
+                            
.to("file://target/multicast/out/?fileName=header.txt")
+                            .to("mock:header")
+                        .end()
+                        .pipeline()
+                            .transform(body().prepend("FOOTER:"))
+                            
.to("file://target/multicast/out/?fileName=footer.txt")
+                            .to("mock:footer")
+                        .end()
+                    .end()
+                    .to("mock:end");
+            }
+        });
+        context.start();
+
         MockEndpoint header = getMockEndpoint("mock:header");
         header.expectedBodiesReceived("HEADER:foo");
         header.expectedFileExists("./target/multicast/out/header.txt");
@@ -50,13 +71,12 @@
         assertMockEndpointsSatisfied();
     }
 
-    @Override
-    protected RouteBuilder createRouteBuilder() throws Exception {
-        return new RouteBuilder() {
+    public void testFromFileMulticastParallelToFiles() throws Exception {
+        context.addRoutes(new RouteBuilder() {
             @Override
             public void configure() throws Exception {
                 from("file://target/multicast")
-                    .multicast()
+                    .multicast().parallelProcessing()
                         .pipeline()
                             .transform(body().prepend("HEADER:"))
                             
.to("file://target/multicast/out/?fileName=header.txt")
@@ -70,6 +90,28 @@
                     .end()
                     .to("mock:end");
             }
-        };
+        });
+        context.start();
+
+        MockEndpoint header = getMockEndpoint("mock:header");
+        header.expectedBodiesReceived("HEADER:foo");
+        header.expectedFileExists("./target/multicast/out/header.txt");
+
+        MockEndpoint footer = getMockEndpoint("mock:footer");
+        footer.expectedBodiesReceived("FOOTER:foo");
+        footer.expectedFileExists("./target/multicast/out/footer.txt");
+
+        MockEndpoint end = getMockEndpoint("mock:end");
+        end.expectedMessageCount(1);
+        end.expectedFileExists("./target/multicast/.camel/foo.txt");
+
+        template.sendBodyAndHeader("file://target/multicast", "foo", 
Exchange.FILE_NAME, "foo.txt");
+
+        assertMockEndpointsSatisfied();
+    }
+
+    @Override
+    public boolean isUseRouteBuilder() {
+        return false;
     }
 }