Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

INT-1758 deprecated setPollerMetadata() on AbstractPollingEndpoint

Browse Source
This commit is contained in:
Oleg Zhurakousky
2011-01-21 11:31:04 -05:00
parent 93f6568c9c
commit dddf29a39d
2 changed files with 14 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
spring-integration-core/src/main/java/org/springframework/integration/endpoint/AbstractPollingEndpoint.java
View File

@@ -30,6 +30,7 @@ import org.springframework.integration.MessageHandlingException;
import org.springframework.integration.MessagingException;
import org.springframework.integration.channel.MessagePublishingErrorHandler;
import org.springframework.integration.message.ErrorMessage;
import org.springframework.integration.scheduling.PollerMetadata;
import org.springframework.integration.support.channel.BeanFactoryChannelResolver;
import org.springframework.integration.util.ErrorHandlingTaskExecutor;
import org.springframework.scheduling.Trigger;
@@ -46,7 +47,7 @@ import org.springframework.util.ErrorHandler;
public abstract class AbstractPollingEndpoint extends AbstractEndpoint implements BeanClassLoaderAware {
private volatile Executor taskExecutor = new SyncTaskExecutor();
private volatile ErrorHandler errorHandler;
private volatile Trigger trigger = new PeriodicTrigger(10);
@@ -70,6 +71,17 @@ public abstract class AbstractPollingEndpoint extends AbstractEndpoint implement
this.setPhase(Integer.MAX_VALUE);
}
/**
* @deprecated As of release 2.0.2, use individual setters
*/
public void setPollerMetadata(PollerMetadata pollerMetadata){
Assert.notNull(pollerMetadata, "'pollerMetadata' must not be null.");
this.setAdviceChain(pollerMetadata.getAdviceChain());
this.setMaxMessagesPerPoll(pollerMetadata.getMaxMessagesPerPoll());
this.setTaskExecutor(pollerMetadata.getTaskExecutor());
this.setTrigger(pollerMetadata.getTrigger());
}
public void setTaskExecutor(Executor taskExecutor) {
this.taskExecutor = (taskExecutor != null ? taskExecutor : new SyncTaskExecutor());
}