INT-1380 added file sample

getting-started/file/src/main/java/org/springframework/integration/samples/filecopy/FileCopyDemoCommon.java

@@ -0,0 +1,42 @@
+/*
+ * Copyright 2002-2010 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.integration.samples.filecopy;
+
+import java.io.File;
+
+import org.springframework.beans.DirectFieldAccessor;
+import org.springframework.context.ApplicationContext;
+import org.springframework.integration.file.FileReadingMessageSource;
+import org.springframework.integration.file.FileWritingMessageHandler;
+
+/**
+ * Displays the names of the input and output directories.
+ * 
+ * @author Marius Bogoevici
+ * @author Mark Fisher
+ */
+public class FileCopyDemoCommon {
+
+	public static void displayDirectories(ApplicationContext context) {
+		File inDir = (File) new DirectFieldAccessor(context.getBean(FileReadingMessageSource.class)).getPropertyValue("directory");
+		File outDir = (File) new DirectFieldAccessor(context.getBean(FileWritingMessageHandler.class)).getPropertyValue("destinationDirectory");
+		System.out.println("Input directory is: " + inDir.getAbsolutePath());
+		System.out.println("Output directory is: " + outDir.getAbsolutePath());
+		System.out.println("===================================================");
+	}
+
+}

getting-started/file/src/main/java/org/springframework/integration/samples/filecopy/Handler.java

@@ -0,0 +1,44 @@
+/*
+ * Copyright 2002-2010 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.integration.samples.filecopy;
+
+import java.io.File;
+
+/**
+ * A class providing several handling methods for different types of payloads.
+ * 
+ * @author Mark Fisher
+ * @author Marius Bogoevici
+ */
+public class Handler {
+
+	public String handleString(String input) {
+		System.out.println("Copying text: " + input);
+		return input.toUpperCase();
+	}
+	
+	public File handleFile(File input) {
+		System.out.println("Copying file: " + input.getAbsolutePath());
+		return input;
+	}
+	
+	public byte[] handleBytes(byte[] input) {
+		System.out.println("Copying " + input.length + " bytes ...");
+		return new String(input).toUpperCase().getBytes();
+	}
+
+}

getting-started/file/src/main/resources/META-INF/spring/integration/fileCopyDemo-binary.xml

@@ -0,0 +1,32 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans xmlns="http://www.springframework.org/schema/beans"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xmlns:integration="http://www.springframework.org/schema/integration"
+	xmlns:file="http://www.springframework.org/schema/integration/file"
+	xsi:schemaLocation="http://www.springframework.org/schema/beans
+			http://www.springframework.org/schema/beans/spring-beans.xsd
+			http://www.springframework.org/schema/integration
+			http://www.springframework.org/schema/integration/spring-integration.xsd
+			http://www.springframework.org/schema/integration/file
+			http://www.springframework.org/schema/integration/file/spring-integration-file.xsd">
+
+	<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
+
+	<file:inbound-channel-adapter id="filesIn"
+	                              directory="file:${java.io.tmpdir}/spring-integration-samples/input"/>
+
+	<file:file-to-bytes-transformer input-channel="filesIn" output-channel="bytes" delete-files="true"/> 
+
+	<integration:channel id="bytes"/>
+
+	<integration:service-activator input-channel="bytes"
+	                               output-channel="filesOut"
+                                   ref="handler"/>
+
+	<file:outbound-channel-adapter id="filesOut" directory="file:${java.io.tmpdir}/spring-integration-samples/output"/>
+
+	<bean id="handler" class="org.springframework.integration.samples.filecopy.Handler"/>
+
+	<integration:poller id="poller" default="true" fixed-delay="5000"/>
+
+</beans>

getting-started/file/src/main/resources/META-INF/spring/integration/fileCopyDemo-file.xml

@@ -0,0 +1,30 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans xmlns="http://www.springframework.org/schema/beans"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xmlns:integration="http://www.springframework.org/schema/integration"
+	xmlns:file="http://www.springframework.org/schema/integration/file"
+	xsi:schemaLocation="http://www.springframework.org/schema/beans
+			http://www.springframework.org/schema/beans/spring-beans.xsd
+			http://www.springframework.org/schema/integration
+			http://www.springframework.org/schema/integration/spring-integration.xsd
+			http://www.springframework.org/schema/integration/file
+			http://www.springframework.org/schema/integration/file/spring-integration-file.xsd">
+
+	<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
+
+	<file:inbound-channel-adapter id="filesIn"
+	                              directory="file:${java.io.tmpdir}/spring-integration-samples/input">
+	    <integration:poller id="poller" fixed-delay="5000"/>
+	</file:inbound-channel-adapter>
+
+	<integration:service-activator input-channel="filesIn"
+	                               output-channel="filesOut"
+                                   ref="handler"/>
+
+	<file:outbound-channel-adapter id="filesOut"
+								   directory="file:${java.io.tmpdir}/spring-integration-samples/output"
+								   delete-source-files="true"/>
+
+	<bean id="handler" class="org.springframework.integration.samples.filecopy.Handler"/>
+
+</beans>

getting-started/file/src/main/resources/META-INF/spring/integration/fileCopyDemo-text.xml

@@ -0,0 +1,33 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans xmlns="http://www.springframework.org/schema/beans"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xmlns:integration="http://www.springframework.org/schema/integration"
+	xmlns:file="http://www.springframework.org/schema/integration/file"
+	xsi:schemaLocation="http://www.springframework.org/schema/beans
+			http://www.springframework.org/schema/beans/spring-beans.xsd
+			http://www.springframework.org/schema/integration
+			http://www.springframework.org/schema/integration/spring-integration.xsd
+			http://www.springframework.org/schema/integration/file
+			http://www.springframework.org/schema/integration/file/spring-integration-file.xsd">
+
+	<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
+
+	<file:inbound-channel-adapter id="filesIn"
+	                              directory="file:${java.io.tmpdir}/spring-integration-samples/input"
+	                              filename-pattern="[a-z]+.txt">
+		<integration:poller id="poller" fixed-delay="5000"/>
+	</file:inbound-channel-adapter>
+
+	<file:file-to-string-transformer input-channel="filesIn" output-channel="strings"/>
+
+	<integration:channel id="strings"/>
+
+	<integration:service-activator input-channel="strings"
+	                               output-channel="filesOut"
+                                   ref="handler"/>
+
+	<file:outbound-channel-adapter id="filesOut" directory="file:${java.io.tmpdir}/spring-integration-samples/output"/>
+
+	<bean id="handler" class="org.springframework.integration.samples.filecopy.Handler"/>
+
+</beans>

getting-started/file/src/test/java/org/springframework/integration/samples/filecopy/BinaryFileCopyTest.java

@@ -0,0 +1,39 @@
+/*
+ * Copyright 2002-2010 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.integration.samples.filecopy;
+
+import org.junit.Test;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.support.ClassPathXmlApplicationContext;
+
+/**
+ * Demonstrating the file copy scenario using binary file source and target.
+ * See the 'fileCopyDemo-binary.xml' configuration file for details. Notice
+ * that the transformer is configured to delete the source File after it
+ * extracts the content as a byte array.
+ * 
+ * @author Marius Bogoevici
+ */
+public class BinaryFileCopyTest {
+
+	@Test
+	public void testBinaryCopy(){
+		ApplicationContext context = new ClassPathXmlApplicationContext("/META-INF/spring/integration/fileCopyDemo-binary.xml", BinaryFileCopyTest.class);
+		FileCopyDemoCommon.displayDirectories(context);
+	}
+
+}

getting-started/file/src/test/java/org/springframework/integration/samples/filecopy/FileBasedFileCopyTest.java

@@ -0,0 +1,37 @@
+/*
+ * Copyright 2002-2010 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.integration.samples.filecopy;
+
+import org.junit.Test;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.support.ClassPathXmlApplicationContext;
+
+/**
+ * Demonstrating the file copy scenario using file-based source and target.
+ * See the 'fileCopyDemo-file.xml' configuration file for details.
+ *
+ * @author Marius Bogoevici
+ */
+public class FileBasedFileCopyTest {
+
+	@Test
+	public void testFileBasedCopy(){
+		ApplicationContext context = new ClassPathXmlApplicationContext("/META-INF/spring/integration/fileCopyDemo-file.xml", FileBasedFileCopyTest.class);
+		FileCopyDemoCommon.displayDirectories(context);
+	}
+
+}

getting-started/file/src/test/java/org/springframework/integration/samples/filecopy/TextFileCopyTest.java

@@ -0,0 +1,39 @@
+/*
+ * Copyright 2002-2010 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.integration.samples.filecopy;
+
+import org.junit.Test;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.support.ClassPathXmlApplicationContext;
+
+/**
+ * Demonstrating the file copy scenario using text-based source and target.
+ * See the 'fileCopyDemo-text.xml' configuration file for details.
+ * 
+ * @author Mark Fisher
+ * @author Marius Bogoevici
+ */
+public class TextFileCopyTest {
+
+	@Test
+	public void testTextBasedCopy(){
+		ApplicationContext context = new ClassPathXmlApplicationContext("/META-INF/spring/integration/fileCopyDemo-text.xml", TextFileCopyTest.class);
+		FileCopyDemoCommon.displayDirectories(context);
+	}
+	
+}
+

getting-started/file/src/test/resources/log4j.xml

@@ -0,0 +1,32 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE log4j:configuration SYSTEM "log4j.dtd">
+<log4j:configuration xmlns:log4j="http://jakarta.apache.org/log4j/">
+
+	<!-- Appenders -->
+	<appender name="console" class="org.apache.log4j.ConsoleAppender">
+		<param name="Target" value="System.out" />
+		<layout class="org.apache.log4j.PatternLayout">
+			<param name="ConversionPattern" value="%-5p: %c - %m%n" />
+		</layout>
+	</appender>
+
+	<!-- Loggers -->
+	<logger name="org.springframework">
+		<level value="warn" />
+	</logger>
+
+	<logger name="org.springframework.integration.samples">
+		<level value="debug" />
+	</logger>
+
+	<logger name="org.springframework.integration.file">
+		<level value="warn" />
+	</logger>
+
+	<!-- Root Logger -->
+	<root>
+		<priority value="warn" />
+		<appender-ref ref="console" />
+	</root>
+
+</log4j:configuration>