org.springframework.integration.jms.config

Class JmsChannelFactoryBean

java.lang.Object

org.springframework.beans.factory.config.AbstractFactoryBean<AbstractJmsChannel>

org.springframework.integration.jms.config.JmsChannelFactoryBean

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanClassLoaderAware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.FactoryBean<AbstractJmsChannel>, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle

public class JmsChannelFactoryBean
extends org.springframework.beans.factory.config.AbstractFactoryBean<AbstractJmsChannel>
implements org.springframework.context.SmartLifecycle, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.BeanNameAware

Since:

2.0

Author:

Mark Fisher, Oleg Zhurakousky, Gary Russell

Field Summary

Fields inherited from class org.springframework.beans.factory.config.AbstractFactoryBean

logger

Constructor Summary

Constructors

Constructor and Description
JmsChannelFactoryBean()
JmsChannelFactoryBean(boolean messageDriven)

Method Summary

Methods

Modifier and Type	Method and Description
protected AbstractJmsChannel	createInstance()
protected void	destroyInstance(AbstractJmsChannel instance)
java.lang.Class<?>	getObjectType()
int	getPhase()
boolean	isAutoStartup()
boolean	isRunning()
void	setAcceptMessagesWhileStopping(boolean acceptMessagesWhileStopping)
void	setAutoStartup(boolean autoStartup)
void	setBeanName(java.lang.String name)
void	setCacheLevelName(java.lang.String cacheLevelName)
void	setClientId(java.lang.String clientId)
void	setConcurrency(java.lang.String concurrency)
void	setConcurrentConsumers(int concurrentConsumers)
void	setConnectionFactory(javax.jms.ConnectionFactory connectionFactory)
void	setContainerType(java.lang.Class<? extends org.springframework.jms.listener.AbstractMessageListenerContainer> containerType)
void	setDeliveryPersistent(boolean deliveryPersistent)
void	setDestination(javax.jms.Destination destination)
void	setDestinationName(java.lang.String destinationName)
void	setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver)
void	setDurableSubscriptionName(java.lang.String durableSubscriptionName)
void	setErrorHandler(org.springframework.util.ErrorHandler errorHandler)
void	setExceptionListener(javax.jms.ExceptionListener exceptionListener)
void	setExplicitQosEnabled(boolean explicitQosEnabled)
void	setExposeListenerSession(boolean exposeListenerSession)
void	setIdleTaskExecutionLimit(int idleTaskExecutionLimit)
void	setInterceptors(java.util.List<ChannelInterceptor> interceptors)
void	setMaxConcurrentConsumers(int maxConcurrentConsumers)
void	setMaxMessagesPerTask(int maxMessagesPerTask)
void	setMaxSubscribers(int maxSubscribers)
void	setMessageConverter(org.springframework.jms.support.converter.MessageConverter messageConverter)
void	setMessageIdEnabled(boolean messageIdEnabled)
void	setMessageSelector(java.lang.String messageSelector)
void	setMessageTimestampEnabled(boolean messageTimestampEnabled)
void	setPhase(int phase)
void	setPriority(int priority)
void	setPubSubDomain(boolean pubSubDomain)
void	setPubSubNoLocal(boolean pubSubNoLocal)
void	setReceiveTimeout(long receiveTimeout)
void	setRecoveryInterval(long recoveryInterval)
void	setSessionAcknowledgeMode(int sessionAcknowledgeMode)
void	setSessionTransacted(boolean sessionTransacted)
void	setSubscriptionDurable(boolean subscriptionDurable)
void	setTaskExecutor(java.util.concurrent.Executor taskExecutor)
void	setTimeToLive(long timeToLive)
void	setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
void	setTransactionName(java.lang.String transactionName)
void	setTransactionTimeout(int transactionTimeout)
void	start()
void	stop()
void	stop(java.lang.Runnable callback)

Methods inherited from class org.springframework.beans.factory.config.AbstractFactoryBean

afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.beans.factory.DisposableBean

destroy

Constructor Detail

JmsChannelFactoryBean

public JmsChannelFactoryBean()

JmsChannelFactoryBean

public JmsChannelFactoryBean(boolean messageDriven)

Method Detail

setInterceptors

public void setInterceptors(java.util.List<ChannelInterceptor> interceptors)

setDeliveryPersistent

public void setDeliveryPersistent(boolean deliveryPersistent)

setExplicitQosEnabled

public void setExplicitQosEnabled(boolean explicitQosEnabled)

setMessageConverter

public void setMessageConverter(org.springframework.jms.support.converter.MessageConverter messageConverter)

setMessageIdEnabled

public void setMessageIdEnabled(boolean messageIdEnabled)

setMessageTimestampEnabled

public void setMessageTimestampEnabled(boolean messageTimestampEnabled)

setPriority

public void setPriority(int priority)

setTimeToLive

public void setTimeToLive(long timeToLive)

setAcceptMessagesWhileStopping

public void setAcceptMessagesWhileStopping(boolean acceptMessagesWhileStopping)

setAutoStartup

public void setAutoStartup(boolean autoStartup)

setCacheLevelName

public void setCacheLevelName(java.lang.String cacheLevelName)

setClientId

public void setClientId(java.lang.String clientId)

setConcurrency

public void setConcurrency(java.lang.String concurrency)

setConcurrentConsumers

public void setConcurrentConsumers(int concurrentConsumers)

setConnectionFactory

public void setConnectionFactory(javax.jms.ConnectionFactory connectionFactory)

setContainerType

public void setContainerType(java.lang.Class<? extends org.springframework.jms.listener.AbstractMessageListenerContainer> containerType)

setDestination

public void setDestination(javax.jms.Destination destination)

setDestinationName

public void setDestinationName(java.lang.String destinationName)

setDestinationResolver

public void setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver)

setDurableSubscriptionName

public void setDurableSubscriptionName(java.lang.String durableSubscriptionName)

setErrorHandler

public void setErrorHandler(org.springframework.util.ErrorHandler errorHandler)

setExceptionListener

public void setExceptionListener(javax.jms.ExceptionListener exceptionListener)

setExposeListenerSession

public void setExposeListenerSession(boolean exposeListenerSession)

setIdleTaskExecutionLimit

public void setIdleTaskExecutionLimit(int idleTaskExecutionLimit)

setMaxConcurrentConsumers

public void setMaxConcurrentConsumers(int maxConcurrentConsumers)

setMaxMessagesPerTask

public void setMaxMessagesPerTask(int maxMessagesPerTask)

setMessageSelector

public void setMessageSelector(java.lang.String messageSelector)

setPhase

public void setPhase(int phase)

setPubSubDomain

public void setPubSubDomain(boolean pubSubDomain)

setPubSubNoLocal

public void setPubSubNoLocal(boolean pubSubNoLocal)

setReceiveTimeout

public void setReceiveTimeout(long receiveTimeout)

setRecoveryInterval

public void setRecoveryInterval(long recoveryInterval)

setSessionAcknowledgeMode

public void setSessionAcknowledgeMode(int sessionAcknowledgeMode)

setSessionTransacted

public void setSessionTransacted(boolean sessionTransacted)

setSubscriptionDurable

public void setSubscriptionDurable(boolean subscriptionDurable)

setTaskExecutor

public void setTaskExecutor(java.util.concurrent.Executor taskExecutor)

setTransactionManager

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

setTransactionName

public void setTransactionName(java.lang.String transactionName)

setTransactionTimeout

public void setTransactionTimeout(int transactionTimeout)

setMaxSubscribers

public void setMaxSubscribers(int maxSubscribers)

setBeanName

public void setBeanName(java.lang.String name)

Specified by:

setBeanName in interface org.springframework.beans.factory.BeanNameAware

getObjectType

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

Specified by:

getObjectType in interface org.springframework.beans.factory.FactoryBean<AbstractJmsChannel>

Specified by:

getObjectType in class org.springframework.beans.factory.config.AbstractFactoryBean<AbstractJmsChannel>

createInstance

protected AbstractJmsChannel createInstance()
                                     throws java.lang.Exception

Specified by:

createInstance in class org.springframework.beans.factory.config.AbstractFactoryBean<AbstractJmsChannel>

Throws:

java.lang.Exception

isAutoStartup

public boolean isAutoStartup()

Specified by:

isAutoStartup in interface org.springframework.context.SmartLifecycle

getPhase

public int getPhase()

Specified by:

getPhase in interface org.springframework.context.Phased

isRunning

public boolean isRunning()

Specified by:

isRunning in interface org.springframework.context.Lifecycle

start

public void start()

Specified by:

start in interface org.springframework.context.Lifecycle

stop

public void stop()

Specified by:

stop in interface org.springframework.context.Lifecycle

stop

public void stop(java.lang.Runnable callback)

Specified by:

stop in interface org.springframework.context.SmartLifecycle

destroyInstance

protected void destroyInstance(AbstractJmsChannel instance)
                        throws java.lang.Exception

Overrides:

destroyInstance in class org.springframework.beans.factory.config.AbstractFactoryBean<AbstractJmsChannel>

Throws:

java.lang.Exception