org.apache.activemq.artemis.junit

Class AbstractActiveMQClientResource

java.lang.Object

org.junit.rules.ExternalResource

org.apache.activemq.artemis.junit.AbstractActiveMQClientResource

All Implemented Interfaces:

org.junit.rules.TestRule

Direct Known Subclasses:

ActiveMQConsumerResource, ActiveMQProducerResource

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractActiveMQClientResource.ActiveMQClientResourceException

Constructor Summary

Constructors

Constructor and Description
AbstractActiveMQClientResource(org.apache.activemq.artemis.api.core.client.ServerLocator serverLocator)
AbstractActiveMQClientResource(String url)

Method Summary

Modifier and Type	Method and Description
static void	addMessageProperties(org.apache.activemq.artemis.api.core.client.ClientMessage message, Map<String,Object> properties) Adds properties to a ClientMessage
protected void	after()
protected void	before()
protected abstract void	createClient()
boolean	isAutoCreateQueue()
void	setAutoCreateQueue(boolean autoCreateQueue)
protected abstract void	stopClient()

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

AbstractActiveMQClientResource

public AbstractActiveMQClientResource(org.apache.activemq.artemis.api.core.client.ServerLocator serverLocator)

Method Detail

addMessageProperties

public static void addMessageProperties(org.apache.activemq.artemis.api.core.client.ClientMessage message,
                                        Map<String,Object> properties)

Adds properties to a ClientMessage

Parameters:

message -

properties -

before

protected void before()
               throws Throwable

Overrides:

before in class org.junit.rules.ExternalResource

Throws:

Throwable

after

protected void after()

Overrides:

after in class org.junit.rules.ExternalResource

createClient

protected abstract void createClient()

stopClient

protected abstract void stopClient()

isAutoCreateQueue

public boolean isAutoCreateQueue()

setAutoCreateQueue

public void setAutoCreateQueue(boolean autoCreateQueue)