Class ActiveMQDynamicProducerExtension
- java.lang.Object
-
- org.apache.activemq.artemis.junit.ActiveMQDynamicProducerExtension
-
- All Implemented Interfaces:
ActiveMQDynamicProducerOperations,ActiveMQProducerOperations,org.junit.jupiter.api.extension.AfterAllCallback,org.junit.jupiter.api.extension.BeforeAllCallback,org.junit.jupiter.api.extension.Extension
public class ActiveMQDynamicProducerExtension extends Object implements org.junit.jupiter.api.extension.BeforeAllCallback, org.junit.jupiter.api.extension.AfterAllCallback, ActiveMQDynamicProducerOperations, ActiveMQProducerOperations
A JUnit Extension that embeds an dynamic (i.e. unbound) ActiveMQ Artemis ClientProducer into a test.This JUnit Extension is designed to simplify using ActiveMQ Artemis clients in unit tests. Adding the extension 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 { @RegisterExtension private ActiveMQDynamicProducerExtension producer = new ActiveMQDynamicProducerExtension("vm://0"); @Test public void testSomething() throws Exception { // Use the embedded ClientProducer here producer.sendMessage( "test.address", "String Body" ); } }
-
-
Constructor Summary
Constructors Constructor Description ActiveMQDynamicProducerExtension(String url)ActiveMQDynamicProducerExtension(String url, String username, String password)ActiveMQDynamicProducerExtension(String url, SimpleString address)ActiveMQDynamicProducerExtension(String url, SimpleString address, String username, String password)ActiveMQDynamicProducerExtension(org.apache.activemq.artemis.api.core.client.ServerLocator serverLocator)ActiveMQDynamicProducerExtension(org.apache.activemq.artemis.api.core.client.ServerLocator serverLocator, String username, String password)ActiveMQDynamicProducerExtension(org.apache.activemq.artemis.api.core.client.ServerLocator serverLocator, SimpleString address)ActiveMQDynamicProducerExtension(org.apache.activemq.artemis.api.core.client.ServerLocator serverLocator, SimpleString address, String username, String password)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static voidaddMessageProperties(org.apache.activemq.artemis.api.core.client.ClientMessage message, Map<String,Object> properties)voidafterAll(org.junit.jupiter.api.extension.ExtensionContext context)voidbeforeAll(org.junit.jupiter.api.extension.ExtensionContext context)protected voidcreateClient()org.apache.activemq.artemis.api.core.client.ClientMessagecreateMessage()org.apache.activemq.artemis.api.core.client.ClientMessagecreateMessage(byte[] body)org.apache.activemq.artemis.api.core.client.ClientMessagecreateMessage(byte[] body, Map<String,Object> properties)org.apache.activemq.artemis.api.core.client.ClientMessagecreateMessage(String body)org.apache.activemq.artemis.api.core.client.ClientMessagecreateMessage(String body, Map<String,Object> properties)org.apache.activemq.artemis.api.core.client.ClientMessagecreateMessage(Map<String,Object> properties)booleanisAutoCreateQueue()booleanisUseDurableMessage()org.apache.activemq.artemis.api.core.client.ClientMessagesendMessage(byte[] body)org.apache.activemq.artemis.api.core.client.ClientMessagesendMessage(byte[] body, Map<String,Object> properties)org.apache.activemq.artemis.api.core.client.ClientMessagesendMessage(String body)org.apache.activemq.artemis.api.core.client.ClientMessagesendMessage(String body, Map<String,Object> properties)org.apache.activemq.artemis.api.core.client.ClientMessagesendMessage(Map<String,Object> properties)voidsendMessage(org.apache.activemq.artemis.api.core.client.ClientMessage message)org.apache.activemq.artemis.api.core.client.ClientMessagesendMessage(SimpleString targetAddress, byte[] body)org.apache.activemq.artemis.api.core.client.ClientMessagesendMessage(SimpleString targetAddress, byte[] body, Map<String,Object> properties)org.apache.activemq.artemis.api.core.client.ClientMessagesendMessage(SimpleString targetAddress, String body)org.apache.activemq.artemis.api.core.client.ClientMessagesendMessage(SimpleString targetAddress, String body, Map<String,Object> properties)org.apache.activemq.artemis.api.core.client.ClientMessagesendMessage(SimpleString targetAddress, Map<String,Object> properties)voidsendMessage(SimpleString targetAddress, org.apache.activemq.artemis.api.core.client.ClientMessage message)voidsetAutoCreateQueue(boolean autoCreateQueue)voidsetUseDurableMessage(boolean useDurableMessage)voidstopClient()
-
-
-
Constructor Detail
-
ActiveMQDynamicProducerExtension
public ActiveMQDynamicProducerExtension(String url, String username, String password)
-
ActiveMQDynamicProducerExtension
public ActiveMQDynamicProducerExtension(String url)
-
ActiveMQDynamicProducerExtension
public ActiveMQDynamicProducerExtension(org.apache.activemq.artemis.api.core.client.ServerLocator serverLocator, String username, String password)
-
ActiveMQDynamicProducerExtension
public ActiveMQDynamicProducerExtension(org.apache.activemq.artemis.api.core.client.ServerLocator serverLocator)
-
ActiveMQDynamicProducerExtension
public ActiveMQDynamicProducerExtension(String url, SimpleString address, String username, String password)
-
ActiveMQDynamicProducerExtension
public ActiveMQDynamicProducerExtension(String url, SimpleString address)
-
ActiveMQDynamicProducerExtension
public ActiveMQDynamicProducerExtension(org.apache.activemq.artemis.api.core.client.ServerLocator serverLocator, SimpleString address, String username, String password)
-
ActiveMQDynamicProducerExtension
public ActiveMQDynamicProducerExtension(org.apache.activemq.artemis.api.core.client.ServerLocator serverLocator, SimpleString address)
-
-
Method Detail
-
createClient
protected void createClient()
-
isUseDurableMessage
public boolean isUseDurableMessage()
- Specified by:
isUseDurableMessagein interfaceActiveMQProducerOperations
-
setUseDurableMessage
public void setUseDurableMessage(boolean useDurableMessage)
- Specified by:
setUseDurableMessagein interfaceActiveMQProducerOperations
-
stopClient
public void stopClient()
-
createMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage createMessage()
- Specified by:
createMessagein interfaceActiveMQProducerOperations
-
createMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage createMessage(byte[] body)
- Specified by:
createMessagein interfaceActiveMQProducerOperations
-
createMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage createMessage(String body)
- Specified by:
createMessagein interfaceActiveMQProducerOperations
-
createMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage createMessage(Map<String,Object> properties)
- Specified by:
createMessagein interfaceActiveMQProducerOperations
-
createMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage createMessage(byte[] body, Map<String,Object> properties)- Specified by:
createMessagein interfaceActiveMQProducerOperations
-
createMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage createMessage(String body, Map<String,Object> properties)
- Specified by:
createMessagein interfaceActiveMQProducerOperations
-
sendMessage
public void sendMessage(org.apache.activemq.artemis.api.core.client.ClientMessage message)
- Specified by:
sendMessagein interfaceActiveMQDynamicProducerOperations- Specified by:
sendMessagein interfaceActiveMQProducerOperations
-
sendMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessage(byte[] body)
- Specified by:
sendMessagein interfaceActiveMQProducerOperations
-
sendMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessage(String body)
- Specified by:
sendMessagein interfaceActiveMQProducerOperations
-
sendMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessage(Map<String,Object> properties)
- Specified by:
sendMessagein interfaceActiveMQProducerOperations
-
sendMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessage(byte[] body, Map<String,Object> properties)- Specified by:
sendMessagein interfaceActiveMQProducerOperations
-
sendMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessage(String body, Map<String,Object> properties)
- Specified by:
sendMessagein interfaceActiveMQProducerOperations
-
sendMessage
public void sendMessage(SimpleString targetAddress, org.apache.activemq.artemis.api.core.client.ClientMessage message)
- Specified by:
sendMessagein interfaceActiveMQDynamicProducerOperations
-
sendMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessage(SimpleString targetAddress, byte[] body)
- Specified by:
sendMessagein interfaceActiveMQDynamicProducerOperations
-
sendMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessage(SimpleString targetAddress, String body)
- Specified by:
sendMessagein interfaceActiveMQDynamicProducerOperations
-
sendMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessage(SimpleString targetAddress, Map<String,Object> properties)
- Specified by:
sendMessagein interfaceActiveMQDynamicProducerOperations
-
sendMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessage(SimpleString targetAddress, byte[] body, Map<String,Object> properties)
- Specified by:
sendMessagein interfaceActiveMQDynamicProducerOperations
-
sendMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessage(SimpleString targetAddress, String body, Map<String,Object> properties)
- Specified by:
sendMessagein interfaceActiveMQDynamicProducerOperations
-
addMessageProperties
public static void addMessageProperties(org.apache.activemq.artemis.api.core.client.ClientMessage message, Map<String,Object> properties)
-
isAutoCreateQueue
public boolean isAutoCreateQueue()
-
setAutoCreateQueue
public void setAutoCreateQueue(boolean autoCreateQueue)
-
beforeAll
public void beforeAll(org.junit.jupiter.api.extension.ExtensionContext context) throws Exception- Specified by:
beforeAllin interfaceorg.junit.jupiter.api.extension.BeforeAllCallback- Throws:
Exception
-
-