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 targetJmsMessageChannelSpecimplementation type.
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanClassLoaderAware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.FactoryBean<T>,org.springframework.beans.factory.InitializingBean,org.springframework.context.Lifecycle,org.springframework.context.Phased,org.springframework.context.SmartLifecycle,org.springframework.integration.dsl.ComponentsRegistration
- Direct Known Subclasses:
JmsPublishSubscribeMessageChannelSpec
public class JmsMessageChannelSpec<S extends JmsMessageChannelSpec<S,T>,T extends AbstractJmsChannel> extends JmsPollableMessageChannelSpec<S,T>
A
JmsMessageChannelSpec for subscribable
AbstractJmsChannels.- Since:
- 5.0
-
Field Summary
Fields inherited from class org.springframework.integration.jms.dsl.JmsPollableMessageChannelSpec
jmsChannelFactoryBean -
Constructor Summary
Constructors Modifier Constructor Description protectedJmsMessageChannelSpec(javax.jms.ConnectionFactory connectionFactory) -
Method Summary
Modifier and Type Method Description SacceptMessagesWhileStopping(boolean acceptMessagesWhileStopping)SautoStartup(boolean autoStartup)ScacheLevel(java.lang.Integer cacheLevel)Only applies if thecontainerType(Class)is aDefaultMessageListenerContainer.SconcurrentConsumers(int concurrentConsumers)Only applies if thecontainerType(Class)is aDefaultMessageListenerContaineror aSimpleMessageListenerContainer.ScontainerType(java.lang.Class<? extends org.springframework.jms.listener.AbstractMessageListenerContainer> containerType)Configure the type of the container.SerrorHandler(org.springframework.util.ErrorHandler errorHandler)SexposeListenerSession(boolean exposeListenerSession)SidleTaskExecutionLimit(int idleTaskExecutionLimit)Only applies if thecontainerType(Class)is aDefaultMessageListenerContainer.SmaxMessagesPerTask(int maxMessagesPerTask)Only applies if thecontainerType(Class)is aDefaultMessageListenerContainer.SmaxSubscribers(int maxSubscribers)Sphase(int phase)SrecoveryInterval(long recoveryInterval)Only applies if thecontainerType(Class)is aDefaultMessageListenerContainer.SsubscriptionShared(boolean subscriptionShared)StaskExecutor(java.util.concurrent.Executor taskExecutor)Only applies if thecontainerType(Class)is aDefaultMessageListenerContaineror aSimpleMessageListenerContainer.StransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)Only applies if thecontainerType(Class)is aDefaultMessageListenerContainer.StransactionName(java.lang.String transactionName)Only applies if thecontainerType(Class)is aDefaultMessageListenerContainer.StransactionTimeout(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, timeToLiveMethods inherited from class org.springframework.integration.dsl.MessageChannelSpec
datatype, getComponentsToRegister, interceptor, messageConverter, wireTap, wireTap, wireTapMethods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop
-
Constructor Details
-
JmsMessageChannelSpec
protected JmsMessageChannelSpec(javax.jms.ConnectionFactory connectionFactory)
-
-
Method Details
-
containerType
public S containerType(java.lang.Class<? extends org.springframework.jms.listener.AbstractMessageListenerContainer> 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 aDefaultMessageListenerContaineror aSimpleMessageListenerContainer.- Parameters:
concurrentConsumers- the concurrentConsumers.- Returns:
- the current
JmsMessageChannelSpec. - See Also:
DefaultMessageListenerContainer.setConcurrentConsumers(int),SimpleMessageListenerContainer.setConcurrentConsumers(int)
-
maxSubscribers
- Parameters:
maxSubscribers- the maxSubscribers.- Returns:
- the current
JmsMessageChannelSpec. - See Also:
SubscribableJmsChannel.setMaxSubscribers(int)
-
autoStartup
- Parameters:
autoStartup- the autoStartup.- Returns:
- the current
JmsMessageChannelSpec. - See Also:
SmartLifecycle
-
phase
- Parameters:
phase- the phase.- Returns:
- the current
JmsMessageChannelSpec. - See Also:
SmartLifecycle
-
errorHandler
- Parameters:
errorHandler- the errorHandler.- Returns:
- the current
JmsMessageChannelSpec. - See Also:
AbstractMessageListenerContainer.setErrorHandler(ErrorHandler)
-
exposeListenerSession
- Parameters:
exposeListenerSession- the exposeListenerSession.- Returns:
- the current
JmsMessageChannelSpec. - See Also:
AbstractMessageListenerContainer.setExposeListenerSession(boolean)
-
acceptMessagesWhileStopping
- Parameters:
acceptMessagesWhileStopping- the acceptMessagesWhileStopping.- Returns:
- the current
JmsMessageChannelSpec. - See Also:
AbstractMessageListenerContainer.setAcceptMessagesWhileStopping(boolean)
-
idleTaskExecutionLimit
Only applies if thecontainerType(Class)is aDefaultMessageListenerContainer.- Parameters:
idleTaskExecutionLimit- the idleTaskExecutionLimit.- Returns:
- the current
JmsMessageChannelSpec. - See Also:
DefaultMessageListenerContainer.setIdleTaskExecutionLimit(int)
-
maxMessagesPerTask
Only applies if thecontainerType(Class)is aDefaultMessageListenerContainer.- Parameters:
maxMessagesPerTask- the maxMessagesPerTask.- Returns:
- the current
JmsMessageChannelSpec. - See Also:
DefaultMessageListenerContainer.setMaxMessagesPerTask(int)
-
recoveryInterval
Only applies if thecontainerType(Class)is aDefaultMessageListenerContainer.- Parameters:
recoveryInterval- the recoveryInterval.- Returns:
- the current
JmsMessageChannelSpec. - See Also:
DefaultMessageListenerContainer.setRecoveryInterval(long)
-
taskExecutor
Only applies if thecontainerType(Class)is aDefaultMessageListenerContaineror aSimpleMessageListenerContainer.- Parameters:
taskExecutor- the taskExecutor.- Returns:
- the current
JmsMessageChannelSpec. - See Also:
DefaultMessageListenerContainer.setTaskExecutor(Executor),SimpleMessageListenerContainer.setTaskExecutor(Executor)
-
transactionManager
public S transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)Only applies if thecontainerType(Class)is aDefaultMessageListenerContainer.- Parameters:
transactionManager- the transactionManager.- Returns:
- the current
JmsMessageChannelSpec. - See Also:
AbstractPollingMessageListenerContainer.setTransactionManager(PlatformTransactionManager)
-
transactionName
Only applies if thecontainerType(Class)is aDefaultMessageListenerContainer.- Parameters:
transactionName- the transactionName.- Returns:
- the current
JmsMessageChannelSpec. - See Also:
AbstractPollingMessageListenerContainer.setTransactionName(String)
-
transactionTimeout
Only applies if thecontainerType(Class)is aDefaultMessageListenerContainer.- Parameters:
transactionTimeout- the transactionTimeout.- Returns:
- the current
JmsMessageChannelSpec. - See Also:
AbstractPollingMessageListenerContainer.setTransactionTimeout(int)
-
cacheLevel
Only applies if thecontainerType(Class)is aDefaultMessageListenerContainer.- Parameters:
cacheLevel- the value fororg.springframework.jms.listener.DefaultMessageListenerContainer.cacheLevel- Returns:
- the current
JmsMessageChannelSpec. - See Also:
DefaultMessageListenerContainer.setCacheLevel(int)
-
subscriptionShared
- Parameters:
subscriptionShared- the subscription sharedbooleanflag.- Returns:
- the current
JmsMessageChannelSpec. - See Also:
AbstractMessageListenerContainer.setSubscriptionShared(boolean)
-