org.springframework.integration.scheduling
Class PollerMetadata

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

public class PollerMetadata
extends java.lang.Object

Field Summary

static int

MAX_MESSAGES_UNBOUNDED

Constructor Summary

PollerMetadata()

Method Summary

java.util.List<org.aopalliance.aop.Advice>	getAdviceChain()
ErrorHandler	getErrorHandler()
long	getMaxMessagesPerPoll()
long	getReceiveTimeout()
java.util.concurrent.Executor	getTaskExecutor()
Trigger	getTrigger()
void	setAdviceChain(java.util.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	setTaskExecutor(java.util.concurrent.Executor taskExecutor)
void	setTrigger(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(Trigger trigger)

getTrigger

public Trigger getTrigger()

getErrorHandler

public ErrorHandler getErrorHandler()

setErrorHandler

public void setErrorHandler(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()