diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/endpoint/AbstractEndpoint.java b/org.springframework.integration/src/main/java/org/springframework/integration/endpoint/AbstractEndpoint.java index 08babdbc67..138ab6bf7a 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/endpoint/AbstractEndpoint.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/endpoint/AbstractEndpoint.java @@ -25,8 +25,6 @@ import org.springframework.integration.ConfigurationException; import org.springframework.integration.channel.MessageChannelTemplate; import org.springframework.integration.scheduling.TaskScheduler; import org.springframework.integration.scheduling.TaskSchedulerAware; -import org.springframework.transaction.PlatformTransactionManager; -import org.springframework.transaction.TransactionDefinition; /** * The base class for Message Endpoint implementations. @@ -41,10 +39,6 @@ public abstract class AbstractEndpoint implements MessageEndpoint, TaskScheduler private volatile TaskScheduler taskScheduler; - private volatile PlatformTransactionManager transactionManager; - - private volatile TransactionDefinition transactionDefinition; - private final MessageChannelTemplate channelTemplate = new MessageChannelTemplate(); @@ -60,14 +54,6 @@ public abstract class AbstractEndpoint implements MessageEndpoint, TaskScheduler this.taskScheduler = taskScheduler; } - public void setTransactionManager(PlatformTransactionManager transactionManager) { - this.transactionManager = transactionManager; - } - - public void setTransactionDefinition(TransactionDefinition transactionDefinition) { - this.transactionDefinition= transactionDefinition; - } - protected MessageChannelTemplate getChannelTemplate() { return this.channelTemplate; } @@ -90,15 +76,6 @@ public abstract class AbstractEndpoint implements MessageEndpoint, TaskScheduler protected void initialize() throws Exception { } - protected final void configureTransactionSettingsForPoller(AbstractPoller poller) { - if (this.transactionManager != null) { - poller.setTransactionManager(this.transactionManager); - } - if (this.transactionDefinition != null) { - poller.setTransactionDefinition(this.transactionDefinition); - } - } - public String toString() { return (this.name != null) ? this.name : super.toString(); }