Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

File copy samples now use the new 'org.springframework.integration.file' module with the <file:inbound-channel-adapter/> and <file:outbound-channel-adapter/> elements.

Browse Source
This commit is contained in:
Mark Fisher
2008-09-22 04:50:31 +00:00
parent fdb704e086
commit 845474263d
4 changed files with 90 additions and 51 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/filecopy/fileCopyDemo-binary.xml
View File

@@ -1,14 +1,40 @@
<?xml version="1.0" encoding="UTF-8"?>
<beans:beans xmlns="http://www.springframework.org/schema/integration"
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:beans="http://www.springframework.org/schema/beans"
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-2.5.xsd
http://www.springframework.org/schema/integration
http://www.springframework.org/schema/integration/spring-integration-1.0.xsd">
http://www.springframework.org/schema/integration/spring-integration-1.0.xsd
http://www.springframework.org/schema/integration/file
http://www.springframework.org/schema/integration/file/spring-integration-file-1.0.xsd">
<beans:import resource="fileCopyDemo-common.xml"/>
<file-source id="fileSource" type="binary" directory="${java.io.tmpdir}/spring-integration-samples/input"/>
<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
</beans:beans>
<integration:message-bus/>
<file:inbound-channel-adapter id="filesIn"
directory="file:${java.io.tmpdir}/spring-integration-samples/input"/>
<bean class="org.springframework.integration.transformer.TransformerEndpoint">
<constructor-arg>
<bean class="org.springframework.integration.file.transformer.FileToByteArrayTransformer">
<property name="deleteFileAfterTransformation" value="true"/>
</bean>
</constructor-arg>
<property name="inputChannel" ref="filesIn"/>
<property name="outputChannel" ref="bytes"/>
</bean>
<integration:channel id="bytes"/>
<integration:service-activator input-channel="bytes"
output-channel="filesOut"
ref="exclaimer" method="exclaim"/>
<file:outbound-channel-adapter id="filesOut" directory="${java.io.tmpdir}/spring-integration-samples/output"/>
<bean id="exclaimer" class="org.springframework.integration.samples.filecopy.Exclaimer"/>
</beans>

28
org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/filecopy/fileCopyDemo-common.xml
View File

@@ -1,28 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<beans:beans xmlns="http://www.springframework.org/schema/integration"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:beans="http://www.springframework.org/schema/beans"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
http://www.springframework.org/schema/integration
http://www.springframework.org/schema/integration/spring-integration-1.0.xsd">
<beans:bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
<message-bus/>
<channel-adapter id="channel1" source="fileSource">
<poller period="5000"/>
</channel-adapter>
<service-activator input-channel="channel1"
output-channel="channel2"
ref="exclaimer" method="exclaim"/>
<channel-adapter id="channel2" target="fileTarget"/>
<file-target id="fileTarget" directory="${java.io.tmpdir}/spring-integration-samples/output"/>
<beans:bean id="exclaimer" class="org.springframework.integration.samples.filecopy.Exclaimer"/>
</beans:beans>

30
org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/filecopy/fileCopyDemo-file.xml
View File

@@ -1,14 +1,30 @@
<?xml version="1.0" encoding="UTF-8"?>
<beans:beans xmlns="http://www.springframework.org/schema/integration"
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:beans="http://www.springframework.org/schema/beans"
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-2.5.xsd
http://www.springframework.org/schema/integration
http://www.springframework.org/schema/integration/spring-integration-1.0.xsd">
http://www.springframework.org/schema/integration/spring-integration-1.0.xsd
http://www.springframework.org/schema/integration/file
http://www.springframework.org/schema/integration/file/spring-integration-file-1.0.xsd">
<beans:import resource="fileCopyDemo-common.xml"/>
<file-source id="fileSource" type="file" directory="${java.io.tmpdir}/spring-integration-samples/input"/>
<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
</beans:beans>
<integration:message-bus/>
<file:inbound-channel-adapter id="filesIn"
directory="file:${java.io.tmpdir}/spring-integration-samples/input">
<integration:poller period="5000"/>
</file:inbound-channel-adapter>
<integration:service-activator input-channel="filesIn"
output-channel="filesOut"
ref="exclaimer" method="exclaim"/>
<file:outbound-channel-adapter id="filesOut" directory="${java.io.tmpdir}/spring-integration-samples/output"/>
<bean id="exclaimer" class="org.springframework.integration.samples.filecopy.Exclaimer"/>
</beans>

43
org.springframework.integration.samples/src/main/java/org/springframework/integration/samples/filecopy/fileCopyDemo-text.xml
View File

@@ -1,16 +1,41 @@
<?xml version="1.0" encoding="UTF-8"?>
<beans:beans xmlns="http://www.springframework.org/schema/integration"
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:beans="http://www.springframework.org/schema/beans"
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-2.5.xsd
http://www.springframework.org/schema/integration
http://www.springframework.org/schema/integration/spring-integration-1.0.xsd">
http://www.springframework.org/schema/integration/spring-integration-1.0.xsd
http://www.springframework.org/schema/integration/file
http://www.springframework.org/schema/integration/file/spring-integration-file-1.0.xsd">
<beans:import resource="fileCopyDemo-common.xml"/>
<file-source id="fileSource" type="text"
filename-pattern="[a-z]+.txt"
directory="${java.io.tmpdir}/spring-integration-samples/input"/>
<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
</beans:beans>
<integration:message-bus/>
<file:inbound-channel-adapter id="filesIn"
directory="file:${java.io.tmpdir}/spring-integration-samples/input"
filename-pattern="[a-z]+.txt"/>
<bean class="org.springframework.integration.transformer.TransformerEndpoint">
<constructor-arg>
<bean class="org.springframework.integration.file.transformer.FileToStringTransformer">
<property name="deleteFileAfterTransformation" value="true"/>
</bean>
</constructor-arg>
<property name="inputChannel" ref="filesIn"/>
<property name="outputChannel" ref="strings"/>
</bean>
<integration:channel id="strings"/>
<integration:service-activator input-channel="strings"
output-channel="filesOut"
ref="exclaimer" method="exclaim"/>
<file:outbound-channel-adapter id="filesOut" directory="${java.io.tmpdir}/spring-integration-samples/output"/>
<bean id="exclaimer" class="org.springframework.integration.samples.filecopy.Exclaimer"/>
</beans>