mindol1004/spring-boot-rest
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

formatting

Browse Source
This commit is contained in:
enpy303
2019-10-11 11:50:28 +02:00
parent 4dc0e05d52
commit c653a270c0
1 changed files with 9 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
spring-integration/src/main/java/com/baeldung/tx/TxIntegrationConfig.java
View File

@@ -41,7 +41,7 @@ public class TxIntegrationConfig {
private final Logger log = LoggerFactory.getLogger(this.getClass()); private final Logger log = LoggerFactory.getLogger(this.getClass());
public final String INPUT_DIR = "/tmp/tx/"; public final String INPUT_DIR = System.getProperty("java.io.tmpdir") + "/tx/";
public final String FILE_PATTERN = "*.txt"; public final String FILE_PATTERN = "*.txt";
@Autowired @Autowired
@@ -72,28 +72,25 @@ public class TxIntegrationConfig {
@Bean @Bean
public PollerMetadata pollerMetadata() { public PollerMetadata pollerMetadata() {
return Pollers return Pollers.fixedDelay(5000)
.fixedDelay(5000) .advice(transactionInterceptor())
.advice(transactionInterceptor()) .transactionSynchronizationFactory(transactionSynchronizationFactory)
.transactionSynchronizationFactory(transactionSynchronizationFactory) .get();
.get();
} }
private TransactionInterceptor transactionInterceptor() { private TransactionInterceptor transactionInterceptor() {
return new TransactionInterceptorBuilder() return new TransactionInterceptorBuilder().transactionManager(txManager).build();
.transactionManager(txManager)
.build();
} }
@Bean @Bean
public TransactionSynchronizationFactory transactionSynchronizationFactory() { public TransactionSynchronizationFactory transactionSynchronizationFactory() {
ExpressionEvaluatingTransactionSynchronizationProcessor transactionSynchronizationProcessor = ExpressionEvaluatingTransactionSynchronizationProcessor transactionSynchronizationProcessor =
new ExpressionEvaluatingTransactionSynchronizationProcessor(); new ExpressionEvaluatingTransactionSynchronizationProcessor();
SpelExpressionParser spelExpressionParser = new SpelExpressionParser(); SpelExpressionParser spelExpressionParser = new SpelExpressionParser();
transactionSynchronizationProcessor.setAfterCommitExpression(spelExpressionParser.parseExpression( transactionSynchronizationProcessor.setAfterCommitExpression(spelExpressionParser.parseExpression(
"payload.renameTo(new java.io.File(payload.absolutePath + '.PASSED'))")); "payload.renameTo(new java.io.File(payload.absolutePath + '.PASSED'))"));
transactionSynchronizationProcessor.setAfterRollbackExpression(spelExpressionParser.parseExpression( transactionSynchronizationProcessor.setAfterRollbackExpression(spelExpressionParser.parseExpression(
"payload.renameTo(new java.io.File(payload.absolutePath + '.FAILED'))")); "payload.renameTo(new java.io.File(payload.absolutePath + '.FAILED'))"));
return new DefaultTransactionSynchronizationFactory(transactionSynchronizationProcessor); return new DefaultTransactionSynchronizationFactory(transactionSynchronizationProcessor);
} }