public class DefaultJmsListenerContainerFactory extends AbstractJmsListenerContainerFactory<DefaultMessageListenerContainer>
JmsListenerContainerFactory
implementation to build a regular
DefaultMessageListenerContainer
.
This should be the default for most users and a good transition paths for those that are used to build such container definition manually.
Modifier and Type | Field and Description |
---|---|
private BackOff |
backOff |
private java.lang.Integer |
cacheLevel |
private java.lang.String |
cacheLevelName |
private java.lang.String |
concurrency |
private java.lang.Integer |
maxMessagesPerTask |
private java.lang.Long |
receiveTimeout |
private java.lang.Long |
recoveryInterval |
private java.util.concurrent.Executor |
taskExecutor |
private PlatformTransactionManager |
transactionManager |
logger
Constructor and Description |
---|
DefaultJmsListenerContainerFactory() |
Modifier and Type | Method and Description |
---|---|
protected DefaultMessageListenerContainer |
createContainerInstance()
Create an empty container instance.
|
protected void |
initializeContainer(DefaultMessageListenerContainer container)
Further initialize the specified container.
|
void |
setBackOff(BackOff backOff) |
void |
setCacheLevel(java.lang.Integer cacheLevel) |
void |
setCacheLevelName(java.lang.String cacheLevelName) |
void |
setConcurrency(java.lang.String concurrency) |
void |
setMaxMessagesPerTask(java.lang.Integer maxMessagesPerTask) |
void |
setReceiveTimeout(java.lang.Long receiveTimeout) |
void |
setRecoveryInterval(java.lang.Long recoveryInterval) |
void |
setTaskExecutor(java.util.concurrent.Executor taskExecutor) |
void |
setTransactionManager(PlatformTransactionManager transactionManager) |
createListenerContainer, setClientId, setConnectionFactory, setDestinationResolver, setErrorHandler, setMessageConverter, setPhase, setPubSubDomain, setSessionAcknowledgeMode, setSessionTransacted, setSubscriptionDurable, setSubscriptionShared
private java.util.concurrent.Executor taskExecutor
private PlatformTransactionManager transactionManager
private java.lang.Integer cacheLevel
private java.lang.String cacheLevelName
private java.lang.String concurrency
private java.lang.Integer maxMessagesPerTask
private java.lang.Long receiveTimeout
private java.lang.Long recoveryInterval
private BackOff backOff
public void setTaskExecutor(java.util.concurrent.Executor taskExecutor)
public void setTransactionManager(PlatformTransactionManager transactionManager)
public void setCacheLevel(java.lang.Integer cacheLevel)
public void setCacheLevelName(java.lang.String cacheLevelName)
public void setConcurrency(java.lang.String concurrency)
public void setMaxMessagesPerTask(java.lang.Integer maxMessagesPerTask)
public void setReceiveTimeout(java.lang.Long receiveTimeout)
public void setRecoveryInterval(java.lang.Long recoveryInterval)
public void setBackOff(BackOff backOff)
protected DefaultMessageListenerContainer createContainerInstance()
AbstractJmsListenerContainerFactory
createContainerInstance
in class AbstractJmsListenerContainerFactory<DefaultMessageListenerContainer>
protected void initializeContainer(DefaultMessageListenerContainer container)
AbstractJmsListenerContainerFactory
Subclasses can inherit from this method to apply extra configuration if necessary.
initializeContainer
in class AbstractJmsListenerContainerFactory<DefaultMessageListenerContainer>