Package org.apache.activemq.junit

Class AbstractActiveMQClientResource

java.lang.Object

org.junit.rules.ExternalResource

org.apache.activemq.junit.AbstractActiveMQClientResource

All Implemented Interfaces:

org.junit.rules.TestRule

Direct Known Subclasses:

AbstractActiveMQConsumerResource, AbstractActiveMQProducerResource

public abstract class AbstractActiveMQClientResource
extends org.junit.rules.ExternalResource

Constructor Summary

Constructors

Constructor	Description
AbstractActiveMQClientResource(String destinationName, URI brokerURI)
AbstractActiveMQClientResource(String destinationName, URI brokerURI, String userName, String password)
AbstractActiveMQClientResource(String destinationName, org.apache.activemq.ActiveMQConnectionFactory connectionFactory)
AbstractActiveMQClientResource(String destinationName, EmbeddedActiveMQBroker embeddedActiveMQBroker)
AbstractActiveMQClientResource(URI brokerURI)
AbstractActiveMQClientResource(URI brokerURI, String userName, String password)
AbstractActiveMQClientResource(org.apache.activemq.ActiveMQConnectionFactory connectionFactory)
AbstractActiveMQClientResource(EmbeddedActiveMQBroker embeddedActiveMQBroker)

Method Summary

Modifier and Type	Method	Description
protected void	after()	Stop the Client
protected void	before()	Start the Client
javax.jms.BytesMessage	createBytesMessage()
protected abstract void	createClient()
protected org.apache.activemq.command.ActiveMQDestination	createDestination(String destinationName)
javax.jms.MapMessage	createMapMessage()
javax.jms.BytesMessage	createMessage(byte[] body)
javax.jms.BytesMessage	createMessage(byte[] body, Map<String,Object> properties)
javax.jms.ObjectMessage	createMessage(Serializable body)
javax.jms.ObjectMessage	createMessage(Serializable body, Map<String,Object> properties)
javax.jms.TextMessage	createMessage(String body)
javax.jms.TextMessage	createMessage(String body, Map<String,Object> properties)
javax.jms.MapMessage	createMessage(Map<String,Object> body)
javax.jms.MapMessage	createMessage(Map<String,Object> body, Map<String,Object> properties)
javax.jms.ObjectMessage	createObjectMessage()
javax.jms.StreamMessage	createStreamMessage()
javax.jms.TextMessage	createTextMessage()
String	getBrokerURL()
String	getClientId()
String	getDestinationName()
abstract byte	getDestinationType()
static void	setMessageProperties(javax.jms.Message message, Map<String,Object> properties)
void	start()
void	stop()

Methods inherited from class org.junit.rules.ExternalResource

apply

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractActiveMQClientResource

public AbstractActiveMQClientResource(org.apache.activemq.ActiveMQConnectionFactory connectionFactory)

AbstractActiveMQClientResource

public AbstractActiveMQClientResource(URI brokerURI)

AbstractActiveMQClientResource

public AbstractActiveMQClientResource(EmbeddedActiveMQBroker embeddedActiveMQBroker)

AbstractActiveMQClientResource

public AbstractActiveMQClientResource(URI brokerURI,
                                      String userName,
                                      String password)

AbstractActiveMQClientResource

public AbstractActiveMQClientResource(String destinationName,
                                      org.apache.activemq.ActiveMQConnectionFactory connectionFactory)

AbstractActiveMQClientResource

public AbstractActiveMQClientResource(String destinationName,
                                      URI brokerURI)

AbstractActiveMQClientResource

public AbstractActiveMQClientResource(String destinationName,
                                      EmbeddedActiveMQBroker embeddedActiveMQBroker)

AbstractActiveMQClientResource

public AbstractActiveMQClientResource(String destinationName,
                                      URI brokerURI,
                                      String userName,
                                      String password)

Method Detail

setMessageProperties

public static void setMessageProperties(javax.jms.Message message,
                                        Map<String,Object> properties)
                                 throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getClientId

public String getClientId()

getDestinationName

public String getDestinationName()

getDestinationType

public abstract byte getDestinationType()

createClient

protected abstract void createClient()
                              throws javax.jms.JMSException

Throws:

javax.jms.JMSException

before

protected void before()
               throws Throwable

Start the Client

Invoked by JUnit to setup the resource

Overrides:

before in class org.junit.rules.ExternalResource

Throws:

Throwable

after

protected void after()

Stop the Client

Invoked by JUnit to tear down the resource

Overrides:

after in class org.junit.rules.ExternalResource

start

public void start()

stop

public void stop()

getBrokerURL

public String getBrokerURL()

createDestination

protected org.apache.activemq.command.ActiveMQDestination createDestination(String destinationName)

createBytesMessage

public javax.jms.BytesMessage createBytesMessage()
                                          throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createTextMessage

public javax.jms.TextMessage createTextMessage()
                                        throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createMapMessage

public javax.jms.MapMessage createMapMessage()
                                      throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createObjectMessage

public javax.jms.ObjectMessage createObjectMessage()
                                            throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createStreamMessage

public javax.jms.StreamMessage createStreamMessage()
                                            throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createMessage

public javax.jms.BytesMessage createMessage(byte[] body)
                                     throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createMessage

public javax.jms.TextMessage createMessage(String body)
                                    throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createMessage

public javax.jms.MapMessage createMessage(Map<String,Object> body)
                                   throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createMessage

public javax.jms.ObjectMessage createMessage(Serializable body)
                                      throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createMessage

public javax.jms.BytesMessage createMessage(byte[] body,
                                            Map<String,Object> properties)
                                     throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createMessage

public javax.jms.TextMessage createMessage(String body,
                                           Map<String,Object> properties)
                                    throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createMessage

public javax.jms.MapMessage createMessage(Map<String,Object> body,
                                          Map<String,Object> properties)
                                   throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createMessage

public javax.jms.ObjectMessage createMessage(Serializable body,
                                             Map<String,Object> properties)
                                      throws javax.jms.JMSException

Throws:

javax.jms.JMSException