org.springframework.integration.endpoint
Class SourcePollingChannelAdapter

java.lang.Object
  org.springframework.integration.context.IntegrationObjectSupport
      org.springframework.integration.endpoint.AbstractEndpoint
          org.springframework.integration.endpoint.AbstractPollingEndpoint
              org.springframework.integration.endpoint.SourcePollingChannelAdapter

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

public class SourcePollingChannelAdapter
extends AbstractPollingEndpoint

A Channel Adapter implementation for connecting a MessageSource to a MessageChannel.

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

SourcePollingChannelAdapter()

Method Summary

protected boolean	doPoll()
protected void	onInit()
void	setOutputChannel(MessageChannel outputChannel) Specify the MessageChannel where Messages should be sent.
void	setSendTimeout(long sendTimeout) Specify the maximum time to wait for a Message to be sent to the output channel.
void	setSource(MessageSource<?> source) Specify the source to be polled for Messages.

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

afterPropertiesSet, getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, 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

SourcePollingChannelAdapter

public SourcePollingChannelAdapter()

Method Detail

setSource

public void setSource(MessageSource<?> source)

Specify the source to be polled for Messages.

setOutputChannel

public void setOutputChannel(MessageChannel outputChannel)

Specify the MessageChannel where Messages should be sent.

setSendTimeout

public void setSendTimeout(long sendTimeout)

Specify the maximum time to wait for a Message to be sent to the output channel.

onInit

protected void onInit()

Overrides:

onInit in class AbstractPollingEndpoint

doPoll

protected boolean doPoll()

Specified by:

doPoll in class AbstractPollingEndpoint