public abstract class AbstractMessageListenerContainer extends Object implements JMSListenerContainer
Modifier and Type | Field and Description |
---|---|
protected int |
acknowledgeMode |
protected javax.jms.Connection |
connection |
protected javax.jms.Destination |
destination |
protected String |
durableSubscriptionName |
protected Properties |
jndiEnvironment |
protected javax.jms.MessageListener |
listenerHandler |
protected static Logger |
LOG |
protected String |
messageSelector |
protected boolean |
pubSubNoLocal |
protected boolean |
running |
protected boolean |
transacted |
protected TransactionManager |
transactionManager |
Constructor and Description |
---|
AbstractMessageListenerContainer() |
Modifier and Type | Method and Description |
---|---|
InitialContext |
createInitialContext()
Creates a InitialContext if a JNDI environment has been provided.
|
int |
getConcurrentConsumers() |
javax.jms.Connection |
getConnection() |
protected Executor |
getExecutor() |
boolean |
isRunning() |
void |
setAcknowledgeMode(int acknowledgeMode) |
void |
setConcurrentConsumers(int concurrentConsumers) |
void |
setDurableSubscriptionName(String durableSubscriptionName) |
void |
setExecutor(Executor executor) |
void |
setJndiEnvironment(Properties jndiEnvironment) |
void |
setMessageSelector(String messageSelector) |
void |
setPubSubNoLocal(boolean pubSubNoLocal) |
void |
setTransacted(boolean transacted) |
void |
setTransactionManager(TransactionManager transactionManager) |
void |
stop() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
shutdown, start
protected static final Logger LOG
protected javax.jms.Connection connection
protected javax.jms.Destination destination
protected javax.jms.MessageListener listenerHandler
protected boolean transacted
protected int acknowledgeMode
protected String messageSelector
protected boolean running
protected String durableSubscriptionName
protected boolean pubSubNoLocal
protected TransactionManager transactionManager
protected Properties jndiEnvironment
public javax.jms.Connection getConnection()
public void setTransacted(boolean transacted)
public void setAcknowledgeMode(int acknowledgeMode)
public void setMessageSelector(String messageSelector)
protected Executor getExecutor()
public void setExecutor(Executor executor)
public void setJndiEnvironment(Properties jndiEnvironment)
public InitialContext createInitialContext()
public void stop()
stop
in interface JMSListenerContainer
public void setDurableSubscriptionName(String durableSubscriptionName)
public void setPubSubNoLocal(boolean pubSubNoLocal)
public boolean isRunning()
isRunning
in interface JMSListenerContainer
public void setTransactionManager(TransactionManager transactionManager)
public void setConcurrentConsumers(int concurrentConsumers)
public int getConcurrentConsumers()
Apache CXF