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

Spring Integration