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

java config spel fix

Browse Source
This commit is contained in:
enpy303
2019-10-11 00:24:35 +02:00
parent e94f7c56c2
commit 576929f990
1 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -7,7 +7,7 @@ import org.springframework.context.annotation.AnnotationConfigApplicationContext
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.support.AbstractApplicationContext;
import org.springframework.expression.common.LiteralExpression;
import org.springframework.expression.spel.standard.SpelExpressionParser;
import org.springframework.integration.annotation.InboundChannelAdapter;
import org.springframework.integration.annotation.Poller;
import org.springframework.integration.annotation.ServiceActivator;
@@ -86,13 +86,14 @@ public class TxIntegrationConfig {
}
@Bean
public TransactionSynchronizationFactory transactionSynchronizationFactory(){
public TransactionSynchronizationFactory transactionSynchronizationFactory() {
ExpressionEvaluatingTransactionSynchronizationProcessor transactionSynchronizationProcessor =
new ExpressionEvaluatingTransactionSynchronizationProcessor();
transactionSynchronizationProcessor.setAfterCommitExpression(
new LiteralExpression("payload.renameTo(new java.io.File(payload.absolutePath + '.PASSED'))"));
transactionSynchronizationProcessor.setAfterRollbackExpression(
new LiteralExpression("payload.renameTo(new java.io.File(payload.absolutePath + '.FAILED'))"));
new ExpressionEvaluatingTransactionSynchronizationProcessor();
SpelExpressionParser spelExpressionParser = new SpelExpressionParser();
transactionSynchronizationProcessor.setAfterCommitExpression(spelExpressionParser.parseExpression(
"payload.renameTo(new java.io.File(payload.absolutePath + '.PASSED'))"));
transactionSynchronizationProcessor.setAfterRollbackExpression(spelExpressionParser.parseExpression(
"payload.renameTo(new java.io.File(payload.absolutePath + '.FAILED'))"));
return new DefaultTransactionSynchronizationFactory(transactionSynchronizationProcessor);
}