Class JmsMessageChannelSpec<S extends JmsMessageChannelSpec<S,T>,T extends AbstractJmsChannel>
java.lang.Object
org.springframework.beans.factory.config.AbstractFactoryBean<T>
org.springframework.integration.dsl.IntegrationComponentSpec<S,C>
org.springframework.integration.dsl.MessageChannelSpec<S,T>
org.springframework.integration.jms.dsl.JmsPollableMessageChannelSpec<S,T>
org.springframework.integration.jms.dsl.JmsMessageChannelSpec<S,T>
- Type Parameters:
S
- the targetJmsMessageChannelSpec
implementation type.T
- the target channel implementation type.
- All Implemented Interfaces:
Aware
,BeanClassLoaderAware
,BeanFactoryAware
,DisposableBean
,FactoryBean<T>
,InitializingBean
,Lifecycle
,Phased
,SmartLifecycle
,ComponentsRegistration
- Direct Known Subclasses:
JmsPublishSubscribeMessageChannelSpec
public class JmsMessageChannelSpec<S extends JmsMessageChannelSpec<S,T>,T extends AbstractJmsChannel>
extends JmsPollableMessageChannelSpec<S,T>
A
JmsMessageChannelSpec
for subscribable
AbstractJmsChannel
s.- Since:
- 5.0
- Author:
- Artem Bilan, Gary Russell, Artem Vozhdayenko
-
Field Summary
Fields inherited from class org.springframework.integration.jms.dsl.JmsPollableMessageChannelSpec
jmsChannelFactoryBean
Fields inherited from class org.springframework.integration.dsl.MessageChannelSpec
channel
Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
PARSER, target
Fields inherited from class org.springframework.beans.factory.config.AbstractFactoryBean
logger
Fields inherited from interface org.springframework.beans.factory.FactoryBean
OBJECT_TYPE_ATTRIBUTE
Fields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE
-
Constructor Summary
ModifierConstructorDescriptionprotected
JmsMessageChannelSpec
(ConnectionFactory connectionFactory) -
Method Summary
Modifier and TypeMethodDescriptionacceptMessagesWhileStopping
(boolean acceptMessagesWhileStopping) autoStartup
(boolean autoStartup) cacheLevel
(Integer cacheLevel) Only applies if thecontainerType(Class)
is aDefaultMessageListenerContainer
.concurrentConsumers
(int concurrentConsumers) Only applies if thecontainerType(Class)
is aDefaultMessageListenerContainer
or aSimpleMessageListenerContainer
.containerType
(Class<? extends AbstractMessageListenerContainer> containerType) Configure the type of the container.errorHandler
(ErrorHandler errorHandler) exposeListenerSession
(boolean exposeListenerSession) idleTaskExecutionLimit
(int idleTaskExecutionLimit) Only applies if thecontainerType(Class)
is aDefaultMessageListenerContainer
.maxMessagesPerTask
(int maxMessagesPerTask) Only applies if thecontainerType(Class)
is aDefaultMessageListenerContainer
.maxSubscribers
(int maxSubscribers) phase
(int phase) recoveryInterval
(long recoveryInterval) Only applies if thecontainerType(Class)
is aDefaultMessageListenerContainer
.subscriptionShared
(boolean subscriptionShared) taskExecutor
(Executor taskExecutor) Only applies if thecontainerType(Class)
is aDefaultMessageListenerContainer
or aSimpleMessageListenerContainer
.transactionManager
(PlatformTransactionManager transactionManager) Only applies if thecontainerType(Class)
is aDefaultMessageListenerContainer
.transactionName
(String transactionName) Only applies if thecontainerType(Class)
is aDefaultMessageListenerContainer
.transactionTimeout
(int transactionTimeout) Only applies if thecontainerType(Class)
is aDefaultMessageListenerContainer
.Methods inherited from class org.springframework.integration.jms.dsl.JmsPollableMessageChannelSpec
deliveryPersistent, destination, destination, destinationResolver, doGet, explicitQosEnabled, id, jmsMessageConverter, messageIdEnabled, messageSelector, messageTimestampEnabled, priority, receiveTimeout, sessionAcknowledgeMode, sessionTransacted, timeToLive
Methods inherited from class org.springframework.integration.dsl.MessageChannelSpec
datatype, getComponentsToRegister, interceptor, messageConverter, wireTap, wireTap, wireTap
Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop
Methods inherited from class org.springframework.beans.factory.config.AbstractFactoryBean
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
-
Constructor Details
-
JmsMessageChannelSpec
-
-
Method Details
-
containerType
Configure the type of the container.AbstractMessageListenerContainer
. Defaults toDefaultMessageListenerContainer
.- Parameters:
containerType
- the containerType.- Returns:
- the current
JmsMessageChannelSpec
.
-
concurrentConsumers
Only applies if thecontainerType(Class)
is aDefaultMessageListenerContainer
or aSimpleMessageListenerContainer
.- Parameters:
concurrentConsumers
- the concurrentConsumers.- Returns:
- the current
JmsMessageChannelSpec
. - See Also:
-
maxSubscribers
- Parameters:
maxSubscribers
- the maxSubscribers.- Returns:
- the current
JmsMessageChannelSpec
. - See Also:
-
autoStartup
- Parameters:
autoStartup
- the autoStartup.- Returns:
- the current
JmsMessageChannelSpec
. - See Also:
-
phase
- Parameters:
phase
- the phase.- Returns:
- the current
JmsMessageChannelSpec
. - See Also:
-
errorHandler
- Parameters:
errorHandler
- the errorHandler.- Returns:
- the current
JmsMessageChannelSpec
. - See Also:
-
exposeListenerSession
- Parameters:
exposeListenerSession
- the exposeListenerSession.- Returns:
- the current
JmsMessageChannelSpec
. - See Also:
-
acceptMessagesWhileStopping
- Parameters:
acceptMessagesWhileStopping
- the acceptMessagesWhileStopping.- Returns:
- the current
JmsMessageChannelSpec
. - See Also:
-
idleTaskExecutionLimit
Only applies if thecontainerType(Class)
is aDefaultMessageListenerContainer
.- Parameters:
idleTaskExecutionLimit
- the idleTaskExecutionLimit.- Returns:
- the current
JmsMessageChannelSpec
. - See Also:
-
maxMessagesPerTask
Only applies if thecontainerType(Class)
is aDefaultMessageListenerContainer
.- Parameters:
maxMessagesPerTask
- the maxMessagesPerTask.- Returns:
- the current
JmsMessageChannelSpec
. - See Also:
-
recoveryInterval
Only applies if thecontainerType(Class)
is aDefaultMessageListenerContainer
.- Parameters:
recoveryInterval
- the recoveryInterval.- Returns:
- the current
JmsMessageChannelSpec
. - See Also:
-
taskExecutor
Only applies if thecontainerType(Class)
is aDefaultMessageListenerContainer
or aSimpleMessageListenerContainer
.- Parameters:
taskExecutor
- the taskExecutor.- Returns:
- the current
JmsMessageChannelSpec
. - See Also:
-
transactionManager
Only applies if thecontainerType(Class)
is aDefaultMessageListenerContainer
.- Parameters:
transactionManager
- the transactionManager.- Returns:
- the current
JmsMessageChannelSpec
. - See Also:
-
transactionName
Only applies if thecontainerType(Class)
is aDefaultMessageListenerContainer
.- Parameters:
transactionName
- the transactionName.- Returns:
- the current
JmsMessageChannelSpec
. - See Also:
-
transactionTimeout
Only applies if thecontainerType(Class)
is aDefaultMessageListenerContainer
.- Parameters:
transactionTimeout
- the transactionTimeout.- Returns:
- the current
JmsMessageChannelSpec
. - See Also:
-
cacheLevel
Only applies if thecontainerType(Class)
is aDefaultMessageListenerContainer
.- Parameters:
cacheLevel
- the value fororg.springframework.jms.listener.DefaultMessageListenerContainer.cacheLevel
- Returns:
- the current
JmsMessageChannelSpec
. - See Also:
-