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

formatting enhancements

Browse Source
This commit is contained in:
enpy303
2019-10-12 15:39:04 +02:00
parent c653a270c0
commit d937267ed1
1 changed files with 14 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -20,10 +20,7 @@ import org.springframework.integration.file.FileReadingMessageSource;
import org.springframework.integration.file.filters.SimplePatternFileListFilter; import org.springframework.integration.file.filters.SimplePatternFileListFilter;
import org.springframework.integration.file.transformer.FileToStringTransformer; import org.springframework.integration.file.transformer.FileToStringTransformer;
import org.springframework.integration.scheduling.PollerMetadata; import org.springframework.integration.scheduling.PollerMetadata;
import org.springframework.integration.transaction.DefaultTransactionSynchronizationFactory; import org.springframework.integration.transaction.*;
import org.springframework.integration.transaction.ExpressionEvaluatingTransactionSynchronizationProcessor;
import org.springframework.integration.transaction.TransactionInterceptorBuilder;
import org.springframework.integration.transaction.TransactionSynchronizationFactory;
import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DataSourceTransactionManager; import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.jdbc.datasource.embedded.EmbeddedDatabaseBuilder; import org.springframework.jdbc.datasource.embedded.EmbeddedDatabaseBuilder;
@@ -84,14 +81,18 @@ public class TxIntegrationConfig {
@Bean @Bean
public TransactionSynchronizationFactory transactionSynchronizationFactory() { public TransactionSynchronizationFactory transactionSynchronizationFactory() {
ExpressionEvaluatingTransactionSynchronizationProcessor transactionSynchronizationProcessor = ExpressionEvaluatingTransactionSynchronizationProcessor processor =
new ExpressionEvaluatingTransactionSynchronizationProcessor(); new ExpressionEvaluatingTransactionSynchronizationProcessor();
SpelExpressionParser spelExpressionParser = new SpelExpressionParser();
transactionSynchronizationProcessor.setAfterCommitExpression(spelExpressionParser.parseExpression( SpelExpressionParser spelParser = new SpelExpressionParser();
processor.setAfterCommitExpression(
spelParser.parseExpression(
"payload.renameTo(new java.io.File(payload.absolutePath + '.PASSED'))")); "payload.renameTo(new java.io.File(payload.absolutePath + '.PASSED'))"));
transactionSynchronizationProcessor.setAfterRollbackExpression(spelExpressionParser.parseExpression( processor.setAfterRollbackExpression(
spelParser.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(processor);
} }
@Bean @Bean