file-splitter.xml

<?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:int="http://www.springframework.org/schema/integration"
	xmlns:p="http://www.springframework.org/schema/p"
	xmlns:task="http://www.springframework.org/schema/task"
	xsi:schemaLocation="http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-4.1.xsd
		http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
		http://www.springframework.org/schema/integration/file http://www.springframework.org/schema/integration/file/spring-integration-file-3.0.xsd
		http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration.xsd">

	<int:channel id="input"/>

	<int:bridge 
		input-channel="input" 
		output-channel="inputFiles" />
	
	<int:channel id="inputFiles">
	    <int:dispatcher task-executor="executor"/>
	</int:channel>

	<int:splitter 
		input-channel="inputFiles" 
		output-channel="output">
		<bean 
			class="FileSplitter" 
			p:commentPrefix="${commentPrefix:#}" />
	</int:splitter>
	
	<task:executor 
		id="executor" 
		pool-size="${poolSize:8}" 
		queue-capacity="${aueueCapacity:0}" 
		rejection-policy="CALLER_RUNS" />

	<int:channel id="output"/>

</beans>