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

Field Summary
static int MAX_MESSAGES_UNBOUNDED
           
 
Constructor Summary
PollerMetadata()
           
 
Method Summary
 java.util.List<org.aopalliance.aop.Advice> getAdviceChain()
           
 org.springframework.util.ErrorHandler getErrorHandler()
           
 long getMaxMessagesPerPoll()
           
 long getReceiveTimeout()
           
 java.util.concurrent.Executor getTaskExecutor()
           
 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 setTaskExecutor(java.util.concurrent.Executor taskExecutor)
           
 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
Constructor Detail

PollerMetadata

public PollerMetadata()
Method Detail

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()

Spring Integration