Class PollerMetadata
java.lang.Object
org.springframework.integration.scheduling.PollerMetadata
public class PollerMetadata extends Object
- Author:
- Mark Fisher, Oleg Zhurakousky, Gary Russell, Artem Bilan
-
Field Summary
Fields Modifier and Type Field Description static StringDEFAULT_POLLERA convenient short alias for the global default poller bean name.static StringDEFAULT_POLLER_METADATA_BEAN_NAMEThe bean name for global default poller.static longDEFAULT_RECEIVE_TIMEOUTThe default receive timeout as one second.static intMAX_MESSAGES_UNBOUNDEDThe constant for unlimited number of message to poll in one cycle. -
Constructor Summary
Constructors Constructor Description PollerMetadata() -
Method Summary
Modifier and Type Method Description List<Advice>getAdviceChain()static PollerMetadatagetDefaultPollerMetadata(BeanFactory beanFactory)Return the defaultPollerMetadatabean if available.ErrorHandlergetErrorHandler()longgetMaxMessagesPerPoll()longgetReceiveTimeout()longgetSendTimeout()ExecutorgetTaskExecutor()TransactionSynchronizationFactorygetTransactionSynchronizationFactory()TriggergetTrigger()voidsetAdviceChain(List<Advice> adviceChain)voidsetErrorHandler(ErrorHandler errorHandler)voidsetMaxMessagesPerPoll(long maxMessagesPerPoll)Set the maximum number of messages to receive for each poll.voidsetReceiveTimeout(long receiveTimeout)voidsetSendTimeout(long sendTimeout)voidsetTaskExecutor(Executor taskExecutor)voidsetTransactionSynchronizationFactory(TransactionSynchronizationFactory transactionSynchronizationFactory)voidsetTrigger(Trigger trigger)
-
Field Details
-
MAX_MESSAGES_UNBOUNDED
public static final int MAX_MESSAGES_UNBOUNDEDThe constant for unlimited number of message to poll in one cycle.- See Also:
- Constant Field Values
-
DEFAULT_RECEIVE_TIMEOUT
public static final long DEFAULT_RECEIVE_TIMEOUTThe default receive timeout as one second.- See Also:
- Constant Field Values
-
DEFAULT_POLLER_METADATA_BEAN_NAME
The bean name for global default poller.- See Also:
- Constant Field Values
-
DEFAULT_POLLER
A 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
-
getTrigger
-
getErrorHandler
-
setErrorHandler
-
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
-
getAdviceChain
-
setTaskExecutor
-
getTaskExecutor
-
getSendTimeout
public long getSendTimeout() -
setSendTimeout
public void setSendTimeout(long sendTimeout) -
getDefaultPollerMetadata
Return the defaultPollerMetadatabean if available.- Parameters:
beanFactory- BeanFactory for lookup, must not be null.- Returns:
- The poller metadata.
-