S
- the target JmsMessageChannelSpec
implementation type.public class JmsMessageChannelSpec<S extends JmsMessageChannelSpec<S>> extends JmsPollableMessageChannelSpec<S>
JmsMessageChannelSpec
for subscribable AbstractJmsChannel
s.jmsChannelFactoryBean
channel
logger, PARSER, target
deliveryPersistent, destination, destination, destinationResolver, doGet, explicitQosEnabled, id, jmsMessageConverter, messageIdEnabled, messageSelector, messageTimestampEnabled, priority, receiveTimeout, sessionAcknowledgeMode, sessionTransacted, timeToLive
datatype, getComponentsToRegister, interceptor, messageConverter, wireTap, wireTap, wireTap
_this, get, getId, getObject, getObjectType, isSingleton
public S containerType(Class<? extends AbstractMessageListenerContainer> containerType)
AbstractMessageListenerContainer
. Defaults to
DefaultMessageListenerContainer
.containerType
- the containerType.JmsMessageChannelSpec
.public S concurrentConsumers(int concurrentConsumers)
containerType(Class)
is a DefaultMessageListenerContainer
or a SimpleMessageListenerContainer
.concurrentConsumers
- the concurrentConsumers.JmsMessageChannelSpec
.DefaultMessageListenerContainer.setConcurrentConsumers(int)
,
SimpleMessageListenerContainer.setConcurrentConsumers(int)
public S maxSubscribers(int maxSubscribers)
maxSubscribers
- the maxSubscribers.JmsMessageChannelSpec
.SubscribableJmsChannel.setMaxSubscribers(int)
public S autoStartup(boolean autoStartup)
autoStartup
- the autoStartup.JmsMessageChannelSpec
.SmartLifecycle
public S phase(int phase)
phase
- the phase.JmsMessageChannelSpec
.SmartLifecycle
public S errorHandler(ErrorHandler errorHandler)
errorHandler
- the errorHandler.JmsMessageChannelSpec
.AbstractMessageListenerContainer.setErrorHandler(ErrorHandler)
public S exposeListenerSession(boolean exposeListenerSession)
exposeListenerSession
- the exposeListenerSession.JmsMessageChannelSpec
.AbstractMessageListenerContainer.setExposeListenerSession(boolean)
public S acceptMessagesWhileStopping(boolean acceptMessagesWhileStopping)
acceptMessagesWhileStopping
- the acceptMessagesWhileStopping.JmsMessageChannelSpec
.AbstractMessageListenerContainer.setAcceptMessagesWhileStopping(boolean)
public S idleTaskExecutionLimit(int idleTaskExecutionLimit)
containerType(Class)
is a DefaultMessageListenerContainer
.idleTaskExecutionLimit
- the idleTaskExecutionLimit.JmsMessageChannelSpec
.DefaultMessageListenerContainer.setIdleTaskExecutionLimit(int)
public S maxMessagesPerTask(int maxMessagesPerTask)
containerType(Class)
is a DefaultMessageListenerContainer
.maxMessagesPerTask
- the maxMessagesPerTask.JmsMessageChannelSpec
.DefaultMessageListenerContainer.setMaxMessagesPerTask(int)
public S recoveryInterval(long recoveryInterval)
containerType(Class)
is a DefaultMessageListenerContainer
.recoveryInterval
- the recoveryInterval.JmsMessageChannelSpec
.DefaultMessageListenerContainer.setRecoveryInterval(long)
public S taskExecutor(Executor taskExecutor)
containerType(Class)
is a DefaultMessageListenerContainer
or a SimpleMessageListenerContainer
.taskExecutor
- the taskExecutor.JmsMessageChannelSpec
.DefaultMessageListenerContainer.setTaskExecutor(Executor)
,
SimpleMessageListenerContainer.setTaskExecutor(Executor)
public S transactionManager(PlatformTransactionManager transactionManager)
containerType(Class)
is a DefaultMessageListenerContainer
.transactionManager
- the transactionManager.JmsMessageChannelSpec
.AbstractPollingMessageListenerContainer.setTransactionManager(PlatformTransactionManager)
public S transactionName(String transactionName)
containerType(Class)
is a DefaultMessageListenerContainer
.transactionName
- the transactionName.JmsMessageChannelSpec
.AbstractPollingMessageListenerContainer.setTransactionName(String)
public S transactionTimeout(int transactionTimeout)
containerType(Class)
is a DefaultMessageListenerContainer
.transactionTimeout
- the transactionTimeout.JmsMessageChannelSpec
.AbstractPollingMessageListenerContainer.setTransactionTimeout(int)
public S cacheLevel(Integer cacheLevel)
containerType(Class)
is a
DefaultMessageListenerContainer
.cacheLevel
- the value for DefaultMessageListenerContainer.cacheLevel
JmsMessageChannelSpec
.DefaultMessageListenerContainer.setCacheLevel(int)
public S subscriptionShared(boolean subscriptionShared)
subscriptionShared
- the subscription shared boolean
flag.JmsMessageChannelSpec
.AbstractMessageListenerContainer.setSubscriptionShared(boolean)