Class ActiveMQProducerExtension
- java.lang.Object
-
- org.apache.activemq.artemis.junit.ActiveMQProducerExtension
-
- All Implemented Interfaces:
ActiveMQProducerOperations,org.junit.jupiter.api.extension.AfterAllCallback,org.junit.jupiter.api.extension.BeforeAllCallback,org.junit.jupiter.api.extension.Extension
public class ActiveMQProducerExtension extends Object implements org.junit.jupiter.api.extension.BeforeAllCallback, org.junit.jupiter.api.extension.AfterAllCallback, ActiveMQProducerOperations
A JUnit Extension that embeds an ActiveMQ Artemis ClientProducer bound to a specific address 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 a ClientProducer, which can then be used to feed messages to the bound address on an ActiveMQ Artemis server.
public class SimpleTest { @RegisterExtension private ActiveMQProducerExtension producer = new ActiveMQProducerExtension( "vm://0", "test.queue"); @Test public void testSomething() throws Exception { // Use the embedded ClientProducer here producer.sendMessage( "String Body" ); } }
-
-
Constructor Summary
-
Method Summary
-
-
-
Constructor Detail
-
ActiveMQProducerExtension
protected ActiveMQProducerExtension(String url, String username, String password)
-
ActiveMQProducerExtension
protected ActiveMQProducerExtension(String url)
-
ActiveMQProducerExtension
protected ActiveMQProducerExtension(ServerLocator serverLocator, String username, String password)
-
ActiveMQProducerExtension
protected ActiveMQProducerExtension(ServerLocator serverLocator)
-
ActiveMQProducerExtension
public ActiveMQProducerExtension(String url, String address, String username, String password)
-
ActiveMQProducerExtension
public ActiveMQProducerExtension(String url, SimpleString address, String username, String password)
-
ActiveMQProducerExtension
public ActiveMQProducerExtension(String url, SimpleString address)
-
ActiveMQProducerExtension
public ActiveMQProducerExtension(ServerLocator serverLocator, String address, String username, String password)
-
ActiveMQProducerExtension
public ActiveMQProducerExtension(ServerLocator serverLocator, String address)
-
ActiveMQProducerExtension
public ActiveMQProducerExtension(ServerLocator serverLocator, SimpleString address, String username, String password)
-
ActiveMQProducerExtension
public ActiveMQProducerExtension(ServerLocator serverLocator, SimpleString address)
-
-
Method Detail
-
beforeAll
public void beforeAll(org.junit.jupiter.api.extension.ExtensionContext context) throws Exception- Specified by:
beforeAllin interfaceorg.junit.jupiter.api.extension.BeforeAllCallback- Throws:
Exception
-
afterAll
public void afterAll(org.junit.jupiter.api.extension.ExtensionContext context) throws Exception- Specified by:
afterAllin interfaceorg.junit.jupiter.api.extension.AfterAllCallback- Throws:
Exception
-
isUseDurableMessage
public boolean isUseDurableMessage()
- Specified by:
isUseDurableMessagein interfaceActiveMQProducerOperations
-
setUseDurableMessage
public void setUseDurableMessage(boolean useDurableMessage)
- Specified by:
setUseDurableMessagein interfaceActiveMQProducerOperations
-
createClient
protected void createClient()
-
stopClient
protected void stopClient()
-
createMessage
public ClientMessage createMessage()
- Specified by:
createMessagein interfaceActiveMQProducerOperations
-
createMessage
public ClientMessage createMessage(byte[] body)
- Specified by:
createMessagein interfaceActiveMQProducerOperations
-
createMessage
public ClientMessage createMessage(String body)
- Specified by:
createMessagein interfaceActiveMQProducerOperations
-
createMessage
public ClientMessage createMessage(Map<String,Object> properties)
- Specified by:
createMessagein interfaceActiveMQProducerOperations
-
createMessage
public ClientMessage createMessage(byte[] body, Map<String,Object> properties)
- Specified by:
createMessagein interfaceActiveMQProducerOperations
-
createMessage
public ClientMessage createMessage(String body, Map<String,Object> properties)
- Specified by:
createMessagein interfaceActiveMQProducerOperations
-
sendMessage
public void sendMessage(ClientMessage message)
- Specified by:
sendMessagein interfaceActiveMQProducerOperations
-
sendMessage
public ClientMessage sendMessage(byte[] body)
- Specified by:
sendMessagein interfaceActiveMQProducerOperations
-
sendMessage
public ClientMessage sendMessage(String body)
- Specified by:
sendMessagein interfaceActiveMQProducerOperations
-
sendMessage
public ClientMessage sendMessage(Map<String,Object> properties)
- Specified by:
sendMessagein interfaceActiveMQProducerOperations
-
sendMessage
public ClientMessage sendMessage(byte[] body, Map<String,Object> properties)
- Specified by:
sendMessagein interfaceActiveMQProducerOperations
-
sendMessage
public ClientMessage sendMessage(String body, Map<String,Object> properties)
- Specified by:
sendMessagein interfaceActiveMQProducerOperations
-
addMessageProperties
public static void addMessageProperties(ClientMessage message, Map<String,Object> properties)
-
isAutoCreateQueue
public boolean isAutoCreateQueue()
-
setAutoCreateQueue
public void setAutoCreateQueue(boolean autoCreateQueue)
-
-