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_UNBOUNDEDpublic 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.