Spring Integration

org.springframework.integration.scheduling
Class PollerMetadata

java.lang.Object
  extended by 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.

Spring Integration