org.apache.activemq.artemis.junit

Class ActiveMQDynamicProducerResource

java.lang.Object

org.junit.rules.ExternalResource

org.apache.activemq.artemis.junit.AbstractActiveMQClientResource

org.apache.activemq.artemis.junit.ActiveMQProducerResource

org.apache.activemq.artemis.junit.ActiveMQDynamicProducerResource

All Implemented Interfaces:

org.junit.rules.TestRule

public class ActiveMQDynamicProducerResource
extends ActiveMQProducerResource

A JUnit Rule that embeds an dynamic (i.e. unbound) ActiveMQ Artemis ClientProducer into a test. This JUnit Rule is designed to simplify using ActiveMQ Artemis clients in unit tests. Adding the rule to a test will startup an unbound ClientProducer, which can then be used to feed messages to any address on the ActiveMQ Artemis server.

 public class SimpleTest {

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.activemq.artemis.junit.AbstractActiveMQClientResource

AbstractActiveMQClientResource.ActiveMQClientResourceException

Constructor Summary

Constructors

Constructor and Description
ActiveMQDynamicProducerResource(org.apache.activemq.artemis.api.core.client.ServerLocator serverLocator)
ActiveMQDynamicProducerResource(org.apache.activemq.artemis.api.core.client.ServerLocator serverLocator, org.apache.activemq.artemis.api.core.SimpleString address)
ActiveMQDynamicProducerResource(String url)
ActiveMQDynamicProducerResource(String url, org.apache.activemq.artemis.api.core.SimpleString address)

Method Summary

Modifier and Type	Method and Description
protected void	createClient()
void	sendMessage(org.apache.activemq.artemis.api.core.client.ClientMessage message) Send a ClientMessage to the default address on the server
org.apache.activemq.artemis.api.core.client.ClientMessage	sendMessage(org.apache.activemq.artemis.api.core.SimpleString targetAddress, byte[] body) Create a new ClientMessage with the specified body and send to the specified address on the server
org.apache.activemq.artemis.api.core.client.ClientMessage	sendMessage(org.apache.activemq.artemis.api.core.SimpleString targetAddress, byte[] body, Map<String,Object> properties) Create a new ClientMessage with the specified body and and properties and send to the server
void	sendMessage(org.apache.activemq.artemis.api.core.SimpleString targetAddress, org.apache.activemq.artemis.api.core.client.ClientMessage message) Send a ClientMessage to the specified address on the server
org.apache.activemq.artemis.api.core.client.ClientMessage	sendMessage(org.apache.activemq.artemis.api.core.SimpleString targetAddress, Map<String,Object> properties) Create a new ClientMessage with the specified properties and send to the server
org.apache.activemq.artemis.api.core.client.ClientMessage	sendMessage(org.apache.activemq.artemis.api.core.SimpleString targetAddress, String body) Create a new ClientMessage with the specified body and send to the server
org.apache.activemq.artemis.api.core.client.ClientMessage	sendMessage(org.apache.activemq.artemis.api.core.SimpleString targetAddress, String body, Map<String,Object> properties) Create a new ClientMessage with the specified body and and properties and send to the server

Methods inherited from class org.apache.activemq.artemis.junit.ActiveMQProducerResource

createMessage, createMessage, createMessage, createMessage, createMessage, createMessage, isUseDurableMessage, sendMessage, sendMessage, sendMessage, sendMessage, sendMessage, setUseDurableMessage, stopClient

Methods inherited from class org.apache.activemq.artemis.junit.AbstractActiveMQClientResource

addMessageProperties, after, before, isAutoCreateQueue, setAutoCreateQueue

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

ActiveMQDynamicProducerResource

public ActiveMQDynamicProducerResource(String url)

ActiveMQDynamicProducerResource

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

ActiveMQDynamicProducerResource

public ActiveMQDynamicProducerResource(String url,
                                       org.apache.activemq.artemis.api.core.SimpleString address)

ActiveMQDynamicProducerResource

public ActiveMQDynamicProducerResource(org.apache.activemq.artemis.api.core.client.ServerLocator serverLocator,
                                       org.apache.activemq.artemis.api.core.SimpleString address)

Method Detail

createClient

protected void createClient()

Overrides:

createClient in class ActiveMQProducerResource

sendMessage

public void sendMessage(org.apache.activemq.artemis.api.core.client.ClientMessage message)

Send a ClientMessage to the default address on the server

Overrides:

sendMessage in class ActiveMQProducerResource

Parameters:

message - the message to send

sendMessage

public void sendMessage(org.apache.activemq.artemis.api.core.SimpleString targetAddress,
                        org.apache.activemq.artemis.api.core.client.ClientMessage message)

Send a ClientMessage to the specified address on the server

Parameters:

targetAddress - the target address

message - the message to send

sendMessage

public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessage(org.apache.activemq.artemis.api.core.SimpleString targetAddress,
                                                                             byte[] body)

Create a new ClientMessage with the specified body and send to the specified address on the server

Parameters:

targetAddress - the target address

body - the body for the new message

Returns:

the message that was sent

sendMessage

public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessage(org.apache.activemq.artemis.api.core.SimpleString targetAddress,
                                                                             String body)

Create a new ClientMessage with the specified body and send to the server

Parameters:

targetAddress - the target address

body - the body for the new message

Returns:

the message that was sent

sendMessage

public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessage(org.apache.activemq.artemis.api.core.SimpleString targetAddress,
                                                                             Map<String,Object> properties)

Create a new ClientMessage with the specified properties and send to the server

Parameters:

targetAddress - the target address

properties - the properties for the new message

Returns:

the message that was sent

sendMessage

public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessage(org.apache.activemq.artemis.api.core.SimpleString targetAddress,
                                                                             byte[] body,
                                                                             Map<String,Object> properties)

Create a new ClientMessage with the specified body and and properties and send to the server

Parameters:

targetAddress - the target address

properties - the properties for the new message

Returns:

the message that was sent

sendMessage

public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessage(org.apache.activemq.artemis.api.core.SimpleString targetAddress,
                                                                             String body,
                                                                             Map<String,Object> properties)

Create a new ClientMessage with the specified body and and properties and send to the server

Parameters:

targetAddress - the target address

properties - the properties for the new message

Returns:

the message that was sent