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<org.aopalliance.aop.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<org.aopalliance.aop.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 setAdviceChain(List<org.aopalliance.aop.Advice> adviceChain)
public List<org.aopalliance.aop.Advice> getAdviceChain()
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.