org.apache.cxf.transport.jms.util

Class AbstractMessageListenerContainer

java.lang.Object

org.apache.cxf.transport.jms.util.AbstractMessageListenerContainer

All Implemented Interfaces:

JMSListenerContainer

Direct Known Subclasses:

MessageListenerContainer, PollingMessageListenerContainer

public abstract class AbstractMessageListenerContainer
extends Object
implements JMSListenerContainer

Field Summary

Fields

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 Summary

Constructors

Constructor and Description
AbstractMessageListenerContainer()

Method Summary

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.cxf.transport.jms.util.JMSListenerContainer

shutdown, start

Field Detail

LOG

protected static final Logger LOG

connection

protected javax.jms.Connection connection

destination

protected javax.jms.Destination destination

listenerHandler

protected javax.jms.MessageListener listenerHandler

transacted

protected boolean transacted

acknowledgeMode

protected int acknowledgeMode

messageSelector

protected String messageSelector

running

protected boolean running

durableSubscriptionName

protected String durableSubscriptionName

pubSubNoLocal

protected boolean pubSubNoLocal

transactionManager

protected TransactionManager transactionManager

jndiEnvironment

protected Properties jndiEnvironment

Constructor Detail

AbstractMessageListenerContainer

public AbstractMessageListenerContainer()

Method Detail

getConnection

public javax.jms.Connection getConnection()

setTransacted

public void setTransacted(boolean transacted)

setAcknowledgeMode

public void setAcknowledgeMode(int acknowledgeMode)

setMessageSelector

public void setMessageSelector(String messageSelector)

getExecutor

protected Executor getExecutor()

setExecutor

public void setExecutor(Executor executor)

setJndiEnvironment

public void setJndiEnvironment(Properties jndiEnvironment)

createInitialContext

public InitialContext createInitialContext()

Creates a InitialContext if a JNDI environment has been provided. This is usefull in e.g. weblogic, where interaction with JNDI JMS resources is secured. Be careful not to cache the return value in a non thread local scope.

Returns:

an initial context, with the endpoint's JNDI properties, or null if none is provided or if an errur occurs

stop

public void stop()

Specified by:

stop in interface JMSListenerContainer

setDurableSubscriptionName

public void setDurableSubscriptionName(String durableSubscriptionName)

setPubSubNoLocal

public void setPubSubNoLocal(boolean pubSubNoLocal)

isRunning

public boolean isRunning()

Specified by:

isRunning in interface JMSListenerContainer

setTransactionManager

public void setTransactionManager(TransactionManager transactionManager)

setConcurrentConsumers

public void setConcurrentConsumers(int concurrentConsumers)

getConcurrentConsumers

public int getConcurrentConsumers()