Initial commit

Author: Richard Kettelerij

.gitignore

@@ -0,0 +1,39 @@
+### /Users/rickette/.gitignore-boilerplates/Global/OSX.gitignore
+
+.DS_Store
+.AppleDouble
+.LSOverride
+Icon
+
+
+# Thumbnails
+._*
+
+# Files that might appear on external disk
+.Spotlight-V100
+.Trashes
+
+
+### /Users/rickette/.gitignore-boilerplates/Global/IntelliJ.gitignore
+
+*.iml
+*.ipr
+*.iws
+.idea/
+
+
+### /Users/rickette/.gitignore-boilerplates/Java.gitignore
+
+*.class
+
+# Package Files #
+*.jar
+*.war
+*.ear
+
+
+### /Users/rickette/.gitignore-boilerplates/Maven.gitignore
+
+target/
+
+

README

@@ -1 +1 @@
-This file was created by IntelliJ IDEA 11.1.4 for binding GitHub repository
+Demo for guest lecture on Apache Camel

pom.xml

@@ -0,0 +1,33 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>guest-lecture-apache-camel</groupId>
+    <artifactId>guest-lecture-apache-camel</artifactId>
+    <version>1.0</version>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-core</artifactId>
+            <version>2.10.3</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-test</artifactId>
+            <version>2.10.3</version>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-log4j12</artifactId>
+            <version>1.6.6</version>
+        </dependency>
+        <dependency>
+            <groupId>log4j</groupId>
+            <artifactId>log4j</artifactId>
+            <version>1.2.17</version>
+        </dependency>
+    </dependencies>
+</project>

src/main/java/nl/avisi/guestlecture/camel/FileRoute.java

@@ -0,0 +1,15 @@
+package nl.avisi.guestlecture.camel;
+
+import org.apache.camel.LoggingLevel;
+import org.apache.camel.builder.RouteBuilder;
+
+public class FileRoute extends RouteBuilder {
+
+    @Override
+    public void configure() throws Exception {
+        from("file://inbox/?move=../processed").from("direct:sendfile")
+            .log(LoggingLevel.INFO, "Processing file ${headers.CamelFileName}")
+            .transform(body().regexReplaceAll("V", "W"))
+            .to("file://outbox/");
+    }
+}

src/main/java/nl/avisi/guestlecture/camel/Main.java

@@ -0,0 +1,11 @@
+package nl.avisi.guestlecture.camel;
+
+public class Main {
+
+    public static void main(String[] args) throws Exception {
+        org.apache.camel.main.Main main = new org.apache.camel.main.Main();
+        main.enableHangupSupport();
+        main.addRouteBuilder(new FileRoute());
+        main.run();
+    }
+}

src/main/resources/log4j.properties

@@ -0,0 +1,13 @@
+# Set root logger level to WARN.
+log4j.rootLogger=INFO, A1
+
+# A1 is set to be a ConsoleAppender.
+log4j.appender.A1=org.apache.log4j.ConsoleAppender
+
+# A1 uses PatternLayout.
+log4j.appender.A1.layout=org.apache.log4j.PatternLayout
+log4j.appender.A1.layout.ConversionPattern=%d [%t] %-5p %c - %m%n
+
+log4j.logger.org.apache.camel=INFO
+log4j.logger.org.springframework=INFO
+log4j.logger.nl.avisi=DEBUG

src/test/java/nl/avisi/guestlecture/camel/FileRouteTest.java

@@ -0,0 +1,33 @@
+package nl.avisi.guestlecture.camel;
+
+import nl.avisi.guestlecture.camel.FileRoute;
+
+import org.apache.camel.builder.AdviceWithRouteBuilder;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.test.junit4.CamelTestSupport;
+import org.junit.Test;
+
+public class FileRouteTest extends CamelTestSupport {
+
+    @Test
+    public void testConfigure() throws Exception {
+        context.getRouteDefinitions().get(0).adviceWith(context, new AdviceWithRouteBuilder() {
+            @Override
+            public void configure() throws Exception {
+                mockEndpointsAndSkip("file:outbox/");
+            }
+        });
+
+        getMockEndpoint("mock:file:outbox/").expectedMessageCount(1);
+        getMockEndpoint("mock:file:outbox/").expectedBodiesReceived("Hello Wis");
+
+        template.sendBody("direct:sendfile", "Hello Vis");
+
+        assertMockEndpointsSatisfied();
+    }
+
+    @Override
+    protected RouteBuilder createRouteBuilder() throws Exception {
+        return new FileRoute();
+    }
+}