Created
August 28, 2020 17:48
-
-
Save iainporter/3193a815b85836e2425c6b93d09c2140 to your computer and use it in GitHub Desktop.
transaction classes for file poller
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
@Bean | |
PseudoTransactionManager transactionManager() { | |
return new PseudoTransactionManager(); | |
} | |
@Bean | |
TransactionSynchronizationFactory transactionSynchronizationFactory() { | |
ExpressionParser parser = new SpelExpressionParser(); | |
ExpressionEvaluatingTransactionSynchronizationProcessor syncProcessor = | |
new ExpressionEvaluatingTransactionSynchronizationProcessor(); | |
syncProcessor.setBeanFactory(applicationContext.getAutowireCapableBeanFactory()); | |
syncProcessor.setAfterCommitExpression(parser.parseExpression("payload.renameTo(new java.io.File(@inboundProcessedDirectory.path " + | |
" + T(java.io.File).separator + payload.name))")); | |
syncProcessor.setAfterRollbackExpression(parser.parseExpression("payload.renameTo(new java.io.File(@inboundFailedDirectory.path " + | |
" + T(java.io.File).separator + payload.name))")); | |
return new DefaultTransactionSynchronizationFactory(syncProcessor); | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment