Class PollerMetadata
java.lang.Object
org.springframework.integration.scheduling.PollerMetadata
public class PollerMetadata
extends java.lang.Object
-
Field Summary
Fields Modifier and Type Field Description static java.lang.StringDEFAULT_POLLERA convenient short alias for the global default poller bean name.static java.lang.StringDEFAULT_POLLER_METADATA_BEAN_NAMEstatic intMAX_MESSAGES_UNBOUNDED -
Constructor Summary
Constructors Constructor Description PollerMetadata() -
Method Summary
Modifier and Type Method Description java.util.List<org.aopalliance.aop.Advice>getAdviceChain()static PollerMetadatagetDefaultPollerMetadata(org.springframework.beans.factory.BeanFactory beanFactory)Return the defaultPollerMetadatabean if available.org.springframework.util.ErrorHandlergetErrorHandler()longgetMaxMessagesPerPoll()longgetReceiveTimeout()longgetSendTimeout()java.util.concurrent.ExecutorgetTaskExecutor()TransactionSynchronizationFactorygetTransactionSynchronizationFactory()org.springframework.scheduling.TriggergetTrigger()voidsetAdviceChain(java.util.List<org.aopalliance.aop.Advice> adviceChain)voidsetErrorHandler(org.springframework.util.ErrorHandler errorHandler)voidsetMaxMessagesPerPoll(long maxMessagesPerPoll)Set the maximum number of messages to receive for each poll.voidsetReceiveTimeout(long receiveTimeout)voidsetSendTimeout(long sendTimeout)voidsetTaskExecutor(java.util.concurrent.Executor taskExecutor)voidsetTransactionSynchronizationFactory(TransactionSynchronizationFactory transactionSynchronizationFactory)voidsetTrigger(org.springframework.scheduling.Trigger trigger)
-
Field Details
-
MAX_MESSAGES_UNBOUNDED
public static final int MAX_MESSAGES_UNBOUNDED- See Also:
- Constant Field Values
-
DEFAULT_POLLER_METADATA_BEAN_NAME
public static final java.lang.String DEFAULT_POLLER_METADATA_BEAN_NAME- See Also:
- Constant Field Values
-
DEFAULT_POLLER
public static final java.lang.String DEFAULT_POLLERA convenient short alias for the global default poller bean name.- See Also:
- Constant Field Values
-
-
Constructor Details
-
PollerMetadata
public PollerMetadata()
-
-
Method Details
-
setTransactionSynchronizationFactory
public void setTransactionSynchronizationFactory(TransactionSynchronizationFactory transactionSynchronizationFactory) -
getTransactionSynchronizationFactory
-
setTrigger
public void setTrigger(org.springframework.scheduling.Trigger trigger) -
getTrigger
public org.springframework.scheduling.Trigger getTrigger() -
getErrorHandler
public org.springframework.util.ErrorHandler getErrorHandler() -
setErrorHandler
public void setErrorHandler(org.springframework.util.ErrorHandler errorHandler) -
setMaxMessagesPerPoll
public void setMaxMessagesPerPoll(long maxMessagesPerPoll)Set the maximum number of messages to receive for each poll. A non-positive value indicates that polling should repeat as long as non-null messages are being received and successfully sent.The default is unbounded.
- Parameters:
maxMessagesPerPoll- The maxMessagesPerPoll to set.- See Also:
MAX_MESSAGES_UNBOUNDED
-
getMaxMessagesPerPoll
public long getMaxMessagesPerPoll() -
setReceiveTimeout
public void setReceiveTimeout(long receiveTimeout) -
getReceiveTimeout
public long getReceiveTimeout() -
setAdviceChain
public void setAdviceChain(java.util.List<org.aopalliance.aop.Advice> adviceChain) -
getAdviceChain
public java.util.List<org.aopalliance.aop.Advice> getAdviceChain() -
setTaskExecutor
public void setTaskExecutor(java.util.concurrent.Executor taskExecutor) -
getTaskExecutor
public java.util.concurrent.Executor getTaskExecutor() -
getSendTimeout
public long getSendTimeout() -
setSendTimeout
public void setSendTimeout(long sendTimeout) -
getDefaultPollerMetadata
public static PollerMetadata getDefaultPollerMetadata(org.springframework.beans.factory.BeanFactory beanFactory)Return the defaultPollerMetadatabean if available.- Parameters:
beanFactory- BeanFactory for lookup, must not be null.- Returns:
- The poller metadata.
-