org.springframework.integration.scheduling
Class PollerMetadata

java.lang.Object
  org.springframework.integration.scheduling.PollerMetadata

public class PollerMetadata
extends java.lang.Object

Author:

Mark Fisher, Oleg Zhurakousky, Gary Russell

Field Summary

static java.lang.String	DEFAULT_POLLER_METADATA_BEAN_NAME
static int	MAX_MESSAGES_UNBOUNDED

Constructor Summary

PollerMetadata()

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MAX_MESSAGES_UNBOUNDED

public static final int MAX_MESSAGES_UNBOUNDED

See Also:

Constant Field Values

DEFAULT_POLLER_METADATA_BEAN_NAME

public static final java.lang.String DEFAULT_POLLER_METADATA_BEAN_NAME

See Also:

Constant Field Values

Constructor Detail

PollerMetadata

public PollerMetadata()

Method Detail

setTransactionSynchronizationFactory

public void setTransactionSynchronizationFactory(TransactionSynchronizationFactory transactionSynchronizationFactory)

getTransactionSynchronizationFactory

public TransactionSynchronizationFactory getTransactionSynchronizationFactory()

setTrigger

public void setTrigger(org.springframework.scheduling.Trigger trigger)

getTrigger

public org.springframework.scheduling.Trigger getTrigger()

getErrorHandler

public org.springframework.util.ErrorHandler getErrorHandler()

setErrorHandler

public void setErrorHandler(org.springframework.util.ErrorHandler errorHandler)

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.

See Also:

MAX_MESSAGES_UNBOUNDED

getMaxMessagesPerPoll

public long getMaxMessagesPerPoll()

setReceiveTimeout

public void setReceiveTimeout(long receiveTimeout)

getReceiveTimeout

public long getReceiveTimeout()

setAdviceChain

public void setAdviceChain(java.util.List<org.aopalliance.aop.Advice> adviceChain)

getAdviceChain

public java.util.List<org.aopalliance.aop.Advice> getAdviceChain()

setTaskExecutor

public void setTaskExecutor(java.util.concurrent.Executor taskExecutor)

getTaskExecutor

public java.util.concurrent.Executor getTaskExecutor()

getSendTimeout

public long getSendTimeout()

setSendTimeout

public void setSendTimeout(long sendTimeout)

getDefaultPollerMetadata

public static PollerMetadata getDefaultPollerMetadata(org.springframework.beans.factory.BeanFactory beanFactory)

Return the default PollerMetadata bean if available.

Parameters:

beanFactory - BeanFactory for lookup, must not be null.