Spring Integration

org.springframework.integration.jms.config
Class JmsChannelFactoryBean

java.lang.Object
  extended by org.springframework.beans.factory.config.AbstractFactoryBean<AbstractJmsChannel>
      extended by 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
JmsChannelFactoryBean()
           
JmsChannelFactoryBean(boolean messageDriven)
           
 
Method Summary
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

Spring Integration