Create a gist now

Instantly share code, notes, and snippets.

What would you like to do?
<flow name="reliableAcquisition" processingStrategy="synchronous">
<sftp:inbound-endpoint address="sftp://${USER1_NAME}:${USER1_PASSWORD}@${SFTP_HOST}:${SFTP_PORT}/~/input" archiveDir="${archiveDir}">
<idempotent-redelivery-policy idExpression="#[message.outboundProperties['originalFilename']]" maxRedeliveryCount="${maxRedelivery}">
<dead-letter-queue>
<vm:outbound-endpoint exchange-pattern="one-way" path="error-queue"/>
</dead-letter-queue>
</idempotent-redelivery-policy>
</sftp:inbound-endpoint>
<flow-ref name="myErrorProneBusinessLogic" />
</flow>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment