org.springframework.integration.config
Class PollingDispatcherFactoryBean

java.lang.Object
  org.springframework.integration.config.PollingDispatcherFactoryBean

All Implemented Interfaces:

org.springframework.beans.factory.FactoryBean, org.springframework.beans.factory.InitializingBean

public class PollingDispatcherFactoryBean
extends java.lang.Object
implements org.springframework.beans.factory.FactoryBean, org.springframework.beans.factory.InitializingBean

Author:

Mark Fisher

Field Summary

private java.lang.Object	initializationMonitor
private boolean	initialized
private java.lang.String	isolationLevelName
private int	maxMessagesPerPoll
private PollingDispatcher	poller
private java.lang.String	propagationBehaviorName
private long	receiveTimeout
private Schedule	schedule
private long	sendTimeout
private MessageSource<?>	source
private org.springframework.core.task.TaskExecutor	taskExecutor
private org.springframework.transaction.PlatformTransactionManager	transactionManager
private boolean	transactionReadOnly
private int	transactionTimeout
private boolean	validated

Constructor Summary

PollingDispatcherFactoryBean()

Method Summary

void	afterPropertiesSet()
private MessageExchangeTemplate	createMessageExchangeTemplate()
java.lang.Object	getObject()
java.lang.Class<?>	getObjectType()
private void	initPoller()
boolean	isSingleton()
void	setIsolationLevelName(java.lang.String isolationLevelName)
void	setMaxMessagesPerPoll(int maxMessagesPerPoll)
void	setPropagationBehaviorName(java.lang.String propagationBehaviorName)
void	setReceiveTimeout(long receiveTimeout)
void	setSchedule(Schedule schedule)
void	setSendTimeout(long sendTimeout)
void	setSource(MessageSource<?> source)
void	setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
void	setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
void	setTransactionReadOnly(boolean transactionReadOnly)
void	setTransactionTimeout(int transactionTimeout)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

poller

private volatile PollingDispatcher poller

source

private volatile MessageSource<?> source

schedule

private volatile Schedule schedule

receiveTimeout

private volatile long receiveTimeout

sendTimeout

private volatile long sendTimeout

maxMessagesPerPoll

private volatile int maxMessagesPerPoll

taskExecutor

private volatile org.springframework.core.task.TaskExecutor taskExecutor

transactionManager

private volatile org.springframework.transaction.PlatformTransactionManager transactionManager

propagationBehaviorName

private volatile java.lang.String propagationBehaviorName

isolationLevelName

private volatile java.lang.String isolationLevelName

transactionTimeout

private volatile int transactionTimeout

transactionReadOnly

private volatile boolean transactionReadOnly

validated

private volatile boolean validated

initialized

private volatile boolean initialized

initializationMonitor

private final java.lang.Object initializationMonitor

Constructor Detail

PollingDispatcherFactoryBean

public PollingDispatcherFactoryBean()

Method Detail

setSource

public void setSource(MessageSource<?> source)

setSchedule

public void setSchedule(Schedule schedule)

setReceiveTimeout

public void setReceiveTimeout(long receiveTimeout)

setSendTimeout

public void setSendTimeout(long sendTimeout)

setMaxMessagesPerPoll

public void setMaxMessagesPerPoll(int maxMessagesPerPoll)

setTaskExecutor

public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)

setTransactionManager

public void setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)

setPropagationBehaviorName

public void setPropagationBehaviorName(java.lang.String propagationBehaviorName)

setIsolationLevelName

public void setIsolationLevelName(java.lang.String isolationLevelName)

setTransactionTimeout

public void setTransactionTimeout(int transactionTimeout)

setTransactionReadOnly

public void setTransactionReadOnly(boolean transactionReadOnly)

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

getObject

public java.lang.Object getObject()
                           throws java.lang.Exception

Specified by:

getObject in interface org.springframework.beans.factory.FactoryBean

Throws:

java.lang.Exception

getObjectType

public java.lang.Class<?> getObjectType()

Specified by:

getObjectType in interface org.springframework.beans.factory.FactoryBean

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface org.springframework.beans.factory.FactoryBean

initPoller

private void initPoller()

createMessageExchangeTemplate

private MessageExchangeTemplate createMessageExchangeTemplate()