Merge pull request #582 from ghillert/INT-2708
This commit is contained in:
@@ -5,31 +5,30 @@
|
||||
xmlns:int="http://www.springframework.org/schema/integration"
|
||||
xmlns:context="http://www.springframework.org/schema/context"
|
||||
xsi:schemaLocation="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-2.2.xsd
|
||||
http://www.springframework.org/schema/integration/file http://www.springframework.org/schema/integration/file/spring-integration-file.xsd
|
||||
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
|
||||
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd">
|
||||
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
|
||||
|
||||
<context:property-placeholder/>
|
||||
|
||||
<int-file:inbound-channel-adapter id="pseudoTx" channel="input" auto-startup="false"
|
||||
directory="${java.io.tmpdir}/si-test1">
|
||||
<int-file:inbound-channel-adapter id="pseudoTx"
|
||||
channel="input" auto-startup="false" directory="${java.io.tmpdir}/si-test1">
|
||||
<int:poller fixed-rate="500">
|
||||
<int:pseudo-transactional on-success-expression="payload.delete()"
|
||||
on-success-result-channel="successChannel"
|
||||
on-failure-expression="'foo'"
|
||||
on-failure-result-channel="failureChannel"
|
||||
send-timeout="500" />
|
||||
<int:pseudo-transactional
|
||||
on-success-expression="payload.delete()" on-success-result-channel="successChannel"
|
||||
on-failure-expression="'foo'" on-failure-result-channel="failureChannel"
|
||||
send-timeout="500" />
|
||||
</int:poller>
|
||||
</int-file:inbound-channel-adapter>
|
||||
|
||||
<int:channel id="input" />
|
||||
|
||||
|
||||
<int:channel id="successChannel">
|
||||
<int:queue/>
|
||||
<int:queue />
|
||||
</int:channel>
|
||||
|
||||
<int:channel id="failureChannel">
|
||||
<int:queue/>
|
||||
<int:queue />
|
||||
</int:channel>
|
||||
|
||||
<int:channel id="txInput" />
|
||||
|
||||
Reference in New Issue
Block a user