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.BeanNameAware
- Since:
- 2.0
-
Field Summary
-
Constructor Summary
Constructors Constructor Description JmsChannelFactoryBean()JmsChannelFactoryBean(boolean messageDriven) -
Method Summary
Modifier and Type Method Description protected AbstractJmsChannelcreateInstance()protected voiddestroyInstance(AbstractJmsChannel instance)java.lang.Class<?>getObjectType()intgetPhase()booleanisAutoStartup()booleanisRunning()voidsetAcceptMessagesWhileStopping(boolean acceptMessagesWhileStopping)voidsetAutoStartup(boolean autoStartup)voidsetBeanName(java.lang.String name)voidsetCacheLevel(java.lang.Integer cacheLevel)voidsetCacheLevelName(java.lang.String cacheLevelName)voidsetClientId(java.lang.String clientId)voidsetConcurrency(java.lang.String concurrency)voidsetConcurrentConsumers(int concurrentConsumers)voidsetConnectionFactory(javax.jms.ConnectionFactory connectionFactory)voidsetContainerType(java.lang.Class<? extends org.springframework.jms.listener.AbstractMessageListenerContainer> containerType)voidsetDeliveryPersistent(boolean deliveryPersistent)voidsetDestination(javax.jms.Destination destination)voidsetDestinationName(java.lang.String destinationName)voidsetDestinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver)voidsetDurableSubscriptionName(java.lang.String durableSubscriptionName)voidsetErrorHandler(org.springframework.util.ErrorHandler errorHandler)voidsetExceptionListener(javax.jms.ExceptionListener exceptionListener)voidsetExplicitQosEnabled(boolean explicitQosEnabled)voidsetExposeListenerSession(boolean exposeListenerSession)voidsetIdleTaskExecutionLimit(int idleTaskExecutionLimit)voidsetInterceptors(java.util.List<org.springframework.messaging.support.ChannelInterceptor> interceptors)voidsetMaxConcurrentConsumers(int maxConcurrentConsumers)voidsetMaxMessagesPerTask(int maxMessagesPerTask)voidsetMaxSubscribers(int maxSubscribers)voidsetMessageConverter(org.springframework.jms.support.converter.MessageConverter messageConverter)voidsetMessageIdEnabled(boolean messageIdEnabled)voidsetMessageSelector(java.lang.String messageSelector)voidsetMessageTimestampEnabled(boolean messageTimestampEnabled)voidsetPhase(int phase)voidsetPriority(int priority)voidsetPubSubDomain(boolean pubSubDomain)voidsetPubSubNoLocal(boolean pubSubNoLocal)voidsetReceiveTimeout(long receiveTimeout)voidsetRecoveryInterval(long recoveryInterval)voidsetSessionAcknowledgeMode(int sessionAcknowledgeMode)voidsetSessionTransacted(boolean sessionTransacted)voidsetSubscriptionDurable(boolean subscriptionDurable)voidsetSubscriptionShared(boolean subscriptionShared)voidsetTaskExecutor(java.util.concurrent.Executor taskExecutor)voidsetTimeToLive(long timeToLive)voidsetTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)voidsetTransactionName(java.lang.String transactionName)voidsetTransactionTimeout(int transactionTimeout)voidstart()voidstop()voidstop(java.lang.Runnable callback)
-
Constructor Details
-
JmsChannelFactoryBean
public JmsChannelFactoryBean() -
JmsChannelFactoryBean
public JmsChannelFactoryBean(boolean messageDriven)
-
-
Method Details
-
setInterceptors
public void setInterceptors(java.util.List<org.springframework.messaging.support.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) -
setCacheLevel
public void setCacheLevel(java.lang.Integer cacheLevel) -
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) -
setSubscriptionShared
public void setSubscriptionShared(boolean subscriptionShared) -
setBeanName
public void setBeanName(java.lang.String name)- Specified by:
setBeanNamein interfaceorg.springframework.beans.factory.BeanNameAware
-
getObjectType
public java.lang.Class<?> getObjectType()- Specified by:
getObjectTypein interfaceorg.springframework.beans.factory.FactoryBean<AbstractJmsChannel>- Specified by:
getObjectTypein classorg.springframework.beans.factory.config.AbstractFactoryBean<AbstractJmsChannel>
-
createInstance
- Specified by:
createInstancein classorg.springframework.beans.factory.config.AbstractFactoryBean<AbstractJmsChannel>
-
isAutoStartup
public boolean isAutoStartup()- Specified by:
isAutoStartupin interfaceorg.springframework.context.SmartLifecycle
-
getPhase
public int getPhase()- Specified by:
getPhasein interfaceorg.springframework.context.Phased- Specified by:
getPhasein interfaceorg.springframework.context.SmartLifecycle
-
isRunning
public boolean isRunning()- Specified by:
isRunningin interfaceorg.springframework.context.Lifecycle
-
start
public void start()- Specified by:
startin interfaceorg.springframework.context.Lifecycle
-
stop
public void stop()- Specified by:
stopin interfaceorg.springframework.context.Lifecycle
-
stop
public void stop(java.lang.Runnable callback)- Specified by:
stopin interfaceorg.springframework.context.SmartLifecycle
-
destroyInstance
- Overrides:
destroyInstancein classorg.springframework.beans.factory.config.AbstractFactoryBean<AbstractJmsChannel>
-