public class PollerMetadata extends Object
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_POLLER
A convenient short alias for the global default poller bean name.
|
static String |
DEFAULT_POLLER_METADATA_BEAN_NAME |
static int |
MAX_MESSAGES_UNBOUNDED |
Constructor and Description |
---|
PollerMetadata() |
Modifier and Type | Method and Description |
---|---|
List<Advice> |
getAdviceChain() |
static PollerMetadata |
getDefaultPollerMetadata(BeanFactory beanFactory)
Return the default
PollerMetadata bean if available. |
ErrorHandler |
getErrorHandler() |
long |
getMaxMessagesPerPoll() |
long |
getReceiveTimeout() |
long |
getSendTimeout() |
Executor |
getTaskExecutor() |
TransactionSynchronizationFactory |
getTransactionSynchronizationFactory() |
Trigger |
getTrigger() |
void |
setAdviceChain(List<Advice> adviceChain) |
void |
setErrorHandler(ErrorHandler errorHandler) |
void |
setMaxMessagesPerPoll(long maxMessagesPerPoll)
Set the maximum number of messages to receive for each poll.
|
void |
setReceiveTimeout(long receiveTimeout) |
void |
setSendTimeout(long sendTimeout) |
void |
setTaskExecutor(Executor taskExecutor) |
void |
setTransactionSynchronizationFactory(TransactionSynchronizationFactory transactionSynchronizationFactory) |
void |
setTrigger(Trigger trigger) |
public static final int MAX_MESSAGES_UNBOUNDED
public static final String DEFAULT_POLLER_METADATA_BEAN_NAME
public static final String DEFAULT_POLLER
public void setTransactionSynchronizationFactory(TransactionSynchronizationFactory transactionSynchronizationFactory)
public TransactionSynchronizationFactory getTransactionSynchronizationFactory()
public void setTrigger(Trigger trigger)
public Trigger getTrigger()
public ErrorHandler getErrorHandler()
public void setErrorHandler(ErrorHandler errorHandler)
public void setMaxMessagesPerPoll(long maxMessagesPerPoll)
The default is unbounded.
maxMessagesPerPoll
- The maxMessagesPerPoll to set.MAX_MESSAGES_UNBOUNDED
public long getMaxMessagesPerPoll()
public void setReceiveTimeout(long receiveTimeout)
public long getReceiveTimeout()
public void setTaskExecutor(Executor taskExecutor)
public Executor getTaskExecutor()
public long getSendTimeout()
public void setSendTimeout(long sendTimeout)
public static PollerMetadata getDefaultPollerMetadata(BeanFactory beanFactory)
PollerMetadata
bean if available.beanFactory
- BeanFactory for lookup, must not be null.