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 int

MAX_MESSAGES_UNBOUNDED

Constructor Summary

PollerMetadata()

Method Summary

java.util.List<org.aopalliance.aop.Advice>	getAdviceChain()
org.springframework.util.ErrorHandler	getErrorHandler()
long	getMaxMessagesPerPoll()
org.springframework.expression.Expression	getOnFailureExpression()
MessageChannel	getOnFailureResultChannel()
org.springframework.expression.Expression	getOnSuccessExpression()
MessageChannel	getOnSuccessResultChannel()
long	getReceiveTimeout()
long	getSendTimeout()
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	setOnFailureExpression(org.springframework.expression.Expression onFailureExpression)
void	setOnFailureResultChannel(MessageChannel onFailureResultChannel)
void	setOnSuccessExpression(org.springframework.expression.Expression onSuccessExpression)
void	setOnSuccessResultChannel(MessageChannel onSuccessResultChannel)
void	setReceiveTimeout(long receiveTimeout)
void	setSendTimeout(long sendTimeout)
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()

getOnSuccessExpression

public org.springframework.expression.Expression getOnSuccessExpression()

setOnSuccessExpression

public void setOnSuccessExpression(org.springframework.expression.Expression onSuccessExpression)

getOnSuccessResultChannel

public MessageChannel getOnSuccessResultChannel()

setOnSuccessResultChannel

public void setOnSuccessResultChannel(MessageChannel onSuccessResultChannel)

getOnFailureExpression

public org.springframework.expression.Expression getOnFailureExpression()

setOnFailureExpression

public void setOnFailureExpression(org.springframework.expression.Expression onFailureExpression)

getOnFailureResultChannel

public MessageChannel getOnFailureResultChannel()

setOnFailureResultChannel

public void setOnFailureResultChannel(MessageChannel onFailureResultChannel)

getSendTimeout

public long getSendTimeout()

setSendTimeout

public void setSendTimeout(long sendTimeout)