public class PollerMetadata
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
DEFAULT_POLLER_METADATA_BEAN_NAME |
static int |
MAX_MESSAGES_UNBOUNDED |
Constructor and Description |
---|
PollerMetadata() |
Modifier and Type | Method and Description |
---|---|
java.util.List<org.aopalliance.aop.Advice> |
getAdviceChain() |
static PollerMetadata |
getDefaultPollerMetadata(org.springframework.beans.factory.BeanFactory beanFactory)
Return the default
PollerMetadata bean if available. |
org.springframework.util.ErrorHandler |
getErrorHandler() |
long |
getMaxMessagesPerPoll() |
long |
getReceiveTimeout() |
long |
getSendTimeout() |
java.util.concurrent.Executor |
getTaskExecutor() |
TransactionSynchronizationFactory |
getTransactionSynchronizationFactory() |
org.springframework.scheduling.Trigger |
getTrigger() |
void |
setAdviceChain(java.util.List<org.aopalliance.aop.Advice> adviceChain) |
void |
setErrorHandler(org.springframework.util.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(java.util.concurrent.Executor taskExecutor) |
void |
setTransactionSynchronizationFactory(TransactionSynchronizationFactory transactionSynchronizationFactory) |
void |
setTrigger(org.springframework.scheduling.Trigger trigger) |
public static final int MAX_MESSAGES_UNBOUNDED
public static final java.lang.String DEFAULT_POLLER_METADATA_BEAN_NAME
public void setTransactionSynchronizationFactory(TransactionSynchronizationFactory transactionSynchronizationFactory)
public TransactionSynchronizationFactory getTransactionSynchronizationFactory()
public void setTrigger(org.springframework.scheduling.Trigger trigger)
public org.springframework.scheduling.Trigger getTrigger()
public org.springframework.util.ErrorHandler getErrorHandler()
public void setErrorHandler(org.springframework.util.ErrorHandler errorHandler)
public void setMaxMessagesPerPoll(long maxMessagesPerPoll)
The default is unbounded.
MAX_MESSAGES_UNBOUNDED
public long getMaxMessagesPerPoll()
public void setReceiveTimeout(long receiveTimeout)
public long getReceiveTimeout()
public void setAdviceChain(java.util.List<org.aopalliance.aop.Advice> adviceChain)
public java.util.List<org.aopalliance.aop.Advice> getAdviceChain()
public void setTaskExecutor(java.util.concurrent.Executor taskExecutor)
public java.util.concurrent.Executor getTaskExecutor()
public long getSendTimeout()
public void setSendTimeout(long sendTimeout)
public static PollerMetadata getDefaultPollerMetadata(org.springframework.beans.factory.BeanFactory beanFactory)
PollerMetadata
bean if available.beanFactory
- BeanFactory for lookup, must not be null.