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:
BeanClassLoaderAware, BeanFactoryAware, BeanNameAware, InitializingBean, Lifecycle, Phased, SmartLifecycle, NamedComponent

public class PollingConsumer
extends AbstractPollingEndpoint

Message Endpoint that connects any MessageHandler implementation to a PollableChannel.


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, setPollerMetadata, setTaskExecutor, setTrigger
 
Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint
getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop
 
Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport
afterPropertiesSet, getBeanFactory, getComponentName, getComponentType, getConversionService, getTaskScheduler, setBeanFactory, setBeanName, setComponentName, setConversionService, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

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