org.springframework.integration.endpoint
Class PollingConsumer

java.lang.Object
  extended by org.springframework.integration.context.IntegrationObjectSupport
      extended by org.springframework.integration.endpoint.AbstractEndpoint
          extended by org.springframework.integration.endpoint.AbstractPollingEndpoint
              extended by org.springframework.integration.endpoint.PollingConsumer
All Implemented Interfaces:
org.springframework.beans.factory.BeanClassLoaderAware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle

public class PollingConsumer
extends AbstractPollingEndpoint

Message Endpoint that connects any MessageHandler implementation to a PollableChannel.

Author:
Mark Fisher

Field Summary
 
Fields inherited from class org.springframework.integration.endpoint.AbstractPollingEndpoint
MAX_MESSAGES_UNBOUNDED, maxMessagesPerPoll
 
Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport
logger
 
Constructor Summary
PollingConsumer(PollableChannel inputChannel, MessageHandler handler)
           
 
Method Summary
protected  boolean doPoll()
           
 void setReceiveTimeout(long receiveTimeout)
           
 
Methods inherited from class org.springframework.integration.endpoint.AbstractPollingEndpoint
doStart, doStop, onInit, setAdviceChain, setBeanClassLoader, setErrorHandler, setMaxMessagesPerPoll, setTaskExecutor, setTransactionDefinition, setTransactionManager, setTrigger
 
Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint
afterPropertiesSet, isRunning, setAutoStartup, setTaskScheduler, start, stop
 
Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport
getBeanFactory, getBeanName, getChannelResolver, getTaskScheduler, setBeanFactory, setBeanName, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.springframework.beans.factory.InitializingBean
afterPropertiesSet
 

Constructor Detail

PollingConsumer

public PollingConsumer(PollableChannel inputChannel,
                       MessageHandler handler)
Method Detail

setReceiveTimeout

public void setReceiveTimeout(long receiveTimeout)

doPoll

protected boolean doPoll()
Specified by:
doPoll in class AbstractPollingEndpoint