org.apache.activemq.tool

Class AbstractJmsClient

java.lang.Object

org.apache.activemq.tool.AbstractJmsClient

Direct Known Subclasses:

AbstractJmsMeasurableClient

public abstract class AbstractJmsClient
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected String	clientName
protected int	destCount
static String	DESTINATION_SEPARATOR
protected int	destIndex
protected javax.jms.ConnectionFactory	factory
protected javax.jms.Connection	jmsConnection
protected javax.jms.Session	jmsSession

Constructor Summary

Constructors

Constructor and Description
AbstractJmsClient(javax.jms.ConnectionFactory factory)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	commitTxIfNecessary() Helper method that checks if session is transacted and whether to commit the tx based on commitAfterXMsgs property.
protected javax.jms.Destination	createCompositeDestination(byte destinationType, String destName, int destCount)
protected javax.jms.Destination	createCompositeDestination(String destName, int destCount)
protected javax.jms.Destination	createDestination(String destName)
javax.jms.Destination[]	createDestinations(int destCount)
protected javax.jms.Destination	createTemporaryDestination(String destName)
abstract JmsClientProperties	getClient()
String	getClientName()
javax.jms.Connection	getConnection()
int	getDestCount()
protected byte	getDestinationType(String destName)
int	getDestIndex()
javax.jms.ConnectionFactory	getFactory()
javax.jms.Session	getSession()
protected String	getSimpleName(String destName)
abstract void	setClient(JmsClientProperties client)
void	setClientName(String clientName)
void	setDestCount(int destCount)
void	setDestIndex(int destIndex)
void	setFactory(javax.jms.ConnectionFactory factory)

Methods inherited from class java.lang.Object

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

Field Detail

DESTINATION_SEPARATOR

public static final String DESTINATION_SEPARATOR

See Also:

Constant Field Values

factory

protected javax.jms.ConnectionFactory factory

jmsConnection

protected javax.jms.Connection jmsConnection

jmsSession

protected javax.jms.Session jmsSession

destCount

protected int destCount

destIndex

protected int destIndex

clientName

protected String clientName

Constructor Detail

AbstractJmsClient

public AbstractJmsClient(javax.jms.ConnectionFactory factory)

Method Detail

getClient

public abstract JmsClientProperties getClient()

setClient

public abstract void setClient(JmsClientProperties client)

getFactory

public javax.jms.ConnectionFactory getFactory()

setFactory

public void setFactory(javax.jms.ConnectionFactory factory)

getDestCount

public int getDestCount()

setDestCount

public void setDestCount(int destCount)

getDestIndex

public int getDestIndex()

setDestIndex

public void setDestIndex(int destIndex)

getClientName

public String getClientName()

setClientName

public void setClientName(String clientName)

getConnection

public javax.jms.Connection getConnection()
                                   throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getSession

public javax.jms.Session getSession()
                             throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createDestinations

public javax.jms.Destination[] createDestinations(int destCount)
                                           throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createCompositeDestination

protected javax.jms.Destination createCompositeDestination(String destName,
                                               int destCount)
                                                    throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createCompositeDestination

protected javax.jms.Destination createCompositeDestination(byte destinationType,
                                               String destName,
                                               int destCount)
                                                    throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getSimpleName

protected String getSimpleName(String destName)

getDestinationType

protected byte getDestinationType(String destName)

createDestination

protected javax.jms.Destination createDestination(String destName)
                                           throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createTemporaryDestination

protected javax.jms.Destination createTemporaryDestination(String destName)
                                                    throws javax.jms.JMSException

Throws:

javax.jms.JMSException

commitTxIfNecessary

public boolean commitTxIfNecessary()
                            throws javax.jms.JMSException

Helper method that checks if session is transacted and whether to commit the tx based on commitAfterXMsgs property.

Returns:

true if transaction was committed.

Throws:

javax.jms.JMSException - in case the call to JMS Session.commit() fails.