org.springframework.integration.endpoint
Class PollingConsumer

java.lang.Object
  org.springframework.integration.context.IntegrationObjectSupport
      org.springframework.integration.endpoint.AbstractEndpoint
          org.springframework.integration.endpoint.AbstractPollingEndpoint
              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, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, NamedComponent

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()
protected void	onInit() Subclasses may implement this for initialization logic.
void	setReceiveTimeout(long receiveTimeout)

Methods inherited from class org.springframework.integration.endpoint.AbstractPollingEndpoint

doStart, doStop, setAdviceChain, setBeanClassLoader, setErrorHandler, setMaxMessagesPerPoll, setTaskExecutor, setTransactionDefinition, setTransactionManager, 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, getChannelResolver, getComponentName, getComponentType, getConversionService, getTaskScheduler, setBeanFactory, setBeanName, setChannelResolver, setConversionService, 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)

onInit

protected void onInit()

Description copied from class: IntegrationObjectSupport

Subclasses may implement this for initialization logic.

Overrides:

onInit in class AbstractPollingEndpoint

doPoll

protected boolean doPoll()

Specified by:

doPoll in class AbstractPollingEndpoint