Class EmbeddedActiveMQExtension
- java.lang.Object
-
- org.apache.activemq.artemis.junit.EmbeddedActiveMQExtension
-
- All Implemented Interfaces:
EmbeddedActiveMQOperations,org.junit.jupiter.api.extension.AfterAllCallback,org.junit.jupiter.api.extension.BeforeAllCallback,org.junit.jupiter.api.extension.Extension
public class EmbeddedActiveMQExtension extends Object implements org.junit.jupiter.api.extension.BeforeAllCallback, org.junit.jupiter.api.extension.AfterAllCallback, EmbeddedActiveMQOperations
A JUnit Extension that embeds an ActiveMQ Artemis server into a test.This JUnit Extension is designed to simplify using embedded servers in unit tests. Adding the extension to a test will startup an embedded server, which can then be used by client applications.
public class SimpleTest { @RegisterExtension private EmbeddedActiveMQExtension server = new EmbeddedActiveMQExtension(); @Test public void testSomething() throws Exception { // Use the embedded server here } }
-
-
Constructor Summary
Constructors Constructor Description EmbeddedActiveMQExtension()Create a default EmbeddedActiveMQExtensionEmbeddedActiveMQExtension(int serverId)Create a default EmbeddedActiveMQExtension with the specified serverIdEmbeddedActiveMQExtension(String filename)Creates an EmbeddedActiveMQExtension using the specified configuration fileEmbeddedActiveMQExtension(Configuration configuration)Creates an EmbeddedActiveMQExtension using the specified configuration
-
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)Invoked by JUnit to tear down the resource - stops the embedded ActiveMQ Artemis servervoidbeforeAll(org.junit.jupiter.api.extension.ExtensionContext context)Invoked by JUnit to setup the resource - start the embedded ActiveMQ Artemis serverorg.apache.activemq.artemis.api.core.client.ClientMessagebrowseMessage(String queueName)org.apache.activemq.artemis.api.core.client.ClientMessagebrowseMessage(String queueName, long timeout)org.apache.activemq.artemis.api.core.client.ClientMessagebrowseMessage(SimpleString queueName)org.apache.activemq.artemis.api.core.client.ClientMessagebrowseMessage(SimpleString queueName, long timeout)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(String body)org.apache.activemq.artemis.api.core.client.ClientMessagecreateMessageWithProperties(byte[] body, Map<String,Object> properties)org.apache.activemq.artemis.api.core.client.ClientMessagecreateMessageWithProperties(String body, Map<String,Object> properties)org.apache.activemq.artemis.api.core.client.ClientMessagecreateMessageWithProperties(Map<String,Object> properties)QueuecreateQueue(String name)QueuecreateQueue(String address, String name)QueuecreateQueue(SimpleString address, SimpleString name)voidcreateSharedQueue(String name, String user)voidcreateSharedQueue(String address, String name, String user)voidcreateSharedQueue(SimpleString address, SimpleString name, SimpleString user)List<Queue>getBoundQueues(String address)List<Queue>getBoundQueues(SimpleString address)longgetDefaultReceiveTimeout()longgetMessageCount(String queueName)longgetMessageCount(SimpleString queueName)EmbeddedActiveMQgetServer()StringgetServerName()StringgetVmURL()booleanisUseDurableMessage()booleanisUseDurableQueue()QueuelocateQueue(String queueName)QueuelocateQueue(SimpleString queueName)org.apache.activemq.artemis.api.core.client.ClientMessagereceiveMessage(String queueName)org.apache.activemq.artemis.api.core.client.ClientMessagereceiveMessage(String queueName, long timeout)org.apache.activemq.artemis.api.core.client.ClientMessagereceiveMessage(SimpleString queueName)org.apache.activemq.artemis.api.core.client.ClientMessagereceiveMessage(SimpleString queueName, long timeout)org.apache.activemq.artemis.api.core.client.ClientMessagesendMessage(String address, byte[] body)org.apache.activemq.artemis.api.core.client.ClientMessagesendMessage(String address, String body)voidsendMessage(String address, org.apache.activemq.artemis.api.core.client.ClientMessage message)org.apache.activemq.artemis.api.core.client.ClientMessagesendMessage(SimpleString address, byte[] body)org.apache.activemq.artemis.api.core.client.ClientMessagesendMessage(SimpleString address, String body)voidsendMessage(SimpleString address, org.apache.activemq.artemis.api.core.client.ClientMessage message)org.apache.activemq.artemis.api.core.client.ClientMessagesendMessageWithProperties(String address, byte[] body, Map<String,Object> properties)org.apache.activemq.artemis.api.core.client.ClientMessagesendMessageWithProperties(String address, String body, Map<String,Object> properties)org.apache.activemq.artemis.api.core.client.ClientMessagesendMessageWithProperties(String address, Map<String,Object> properties)org.apache.activemq.artemis.api.core.client.ClientMessagesendMessageWithProperties(SimpleString address, byte[] body, Map<String,Object> properties)org.apache.activemq.artemis.api.core.client.ClientMessagesendMessageWithProperties(SimpleString address, String body, Map<String,Object> properties)org.apache.activemq.artemis.api.core.client.ClientMessagesendMessageWithProperties(SimpleString address, Map<String,Object> properties)voidsetDefaultReceiveTimeout(long defaultReceiveTimeout)voidsetUseDurableMessage(boolean useDurableMessage)voidsetUseDurableQueue(boolean useDurableQueue)voidstart()voidstop()
-
-
-
Constructor Detail
-
EmbeddedActiveMQExtension
public EmbeddedActiveMQExtension()
Create a default EmbeddedActiveMQExtension
-
EmbeddedActiveMQExtension
public EmbeddedActiveMQExtension(int serverId)
Create a default EmbeddedActiveMQExtension with the specified serverId- Parameters:
serverId- server id
-
EmbeddedActiveMQExtension
public EmbeddedActiveMQExtension(Configuration configuration)
Creates an EmbeddedActiveMQExtension using the specified configuration- Parameters:
configuration- ActiveMQServer configuration
-
EmbeddedActiveMQExtension
public EmbeddedActiveMQExtension(String filename)
Creates an EmbeddedActiveMQExtension using the specified configuration file- Parameters:
filename- ActiveMQServer configuration file name
-
-
Method Detail
-
start
public void start()
- Specified by:
startin interfaceEmbeddedActiveMQOperations
-
stop
public void stop()
- Specified by:
stopin interfaceEmbeddedActiveMQOperations
-
beforeAll
public void beforeAll(org.junit.jupiter.api.extension.ExtensionContext context) throws ExceptionInvoked by JUnit to setup the resource - start the embedded ActiveMQ Artemis server- Specified by:
beforeAllin interfaceorg.junit.jupiter.api.extension.BeforeAllCallback- Throws:
Exception
-
afterAll
public void afterAll(org.junit.jupiter.api.extension.ExtensionContext context) throws ExceptionInvoked by JUnit to tear down the resource - stops the embedded ActiveMQ Artemis server- Specified by:
afterAllin interfaceorg.junit.jupiter.api.extension.AfterAllCallback- Throws:
Exception
-
addMessageProperties
public static void addMessageProperties(org.apache.activemq.artemis.api.core.client.ClientMessage message, Map<String,Object> properties)
-
isUseDurableMessage
public boolean isUseDurableMessage()
- Specified by:
isUseDurableMessagein interfaceEmbeddedActiveMQOperations
-
setUseDurableMessage
public void setUseDurableMessage(boolean useDurableMessage)
- Specified by:
setUseDurableMessagein interfaceEmbeddedActiveMQOperations
-
isUseDurableQueue
public boolean isUseDurableQueue()
- Specified by:
isUseDurableQueuein interfaceEmbeddedActiveMQOperations
-
setUseDurableQueue
public void setUseDurableQueue(boolean useDurableQueue)
- Specified by:
setUseDurableQueuein interfaceEmbeddedActiveMQOperations
-
getDefaultReceiveTimeout
public long getDefaultReceiveTimeout()
- Specified by:
getDefaultReceiveTimeoutin interfaceEmbeddedActiveMQOperations
-
setDefaultReceiveTimeout
public void setDefaultReceiveTimeout(long defaultReceiveTimeout)
- Specified by:
setDefaultReceiveTimeoutin interfaceEmbeddedActiveMQOperations
-
getServer
public EmbeddedActiveMQ getServer()
- Specified by:
getServerin interfaceEmbeddedActiveMQOperations
-
getServerName
public String getServerName()
- Specified by:
getServerNamein interfaceEmbeddedActiveMQOperations
-
getVmURL
public String getVmURL()
- Specified by:
getVmURLin interfaceEmbeddedActiveMQOperations
-
getMessageCount
public long getMessageCount(String queueName)
- Specified by:
getMessageCountin interfaceEmbeddedActiveMQOperations
-
getMessageCount
public long getMessageCount(SimpleString queueName)
- Specified by:
getMessageCountin interfaceEmbeddedActiveMQOperations
-
locateQueue
public Queue locateQueue(String queueName)
- Specified by:
locateQueuein interfaceEmbeddedActiveMQOperations
-
locateQueue
public Queue locateQueue(SimpleString queueName)
- Specified by:
locateQueuein interfaceEmbeddedActiveMQOperations
-
getBoundQueues
public List<Queue> getBoundQueues(String address)
- Specified by:
getBoundQueuesin interfaceEmbeddedActiveMQOperations
-
getBoundQueues
public List<Queue> getBoundQueues(SimpleString address)
- Specified by:
getBoundQueuesin interfaceEmbeddedActiveMQOperations
-
createQueue
public Queue createQueue(String name)
- Specified by:
createQueuein interfaceEmbeddedActiveMQOperations
-
createQueue
public Queue createQueue(String address, String name)
- Specified by:
createQueuein interfaceEmbeddedActiveMQOperations
-
createQueue
public Queue createQueue(SimpleString address, SimpleString name)
- Specified by:
createQueuein interfaceEmbeddedActiveMQOperations
-
createSharedQueue
public void createSharedQueue(String name, String user)
- Specified by:
createSharedQueuein interfaceEmbeddedActiveMQOperations
-
createSharedQueue
public void createSharedQueue(String address, String name, String user)
- Specified by:
createSharedQueuein interfaceEmbeddedActiveMQOperations
-
createSharedQueue
public void createSharedQueue(SimpleString address, SimpleString name, SimpleString user)
- Specified by:
createSharedQueuein interfaceEmbeddedActiveMQOperations
-
createMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage createMessage()
- Specified by:
createMessagein interfaceEmbeddedActiveMQOperations
-
createMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage createMessage(byte[] body)
- Specified by:
createMessagein interfaceEmbeddedActiveMQOperations
-
createMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage createMessage(String body)
- Specified by:
createMessagein interfaceEmbeddedActiveMQOperations
-
createMessageWithProperties
public org.apache.activemq.artemis.api.core.client.ClientMessage createMessageWithProperties(Map<String,Object> properties)
- Specified by:
createMessageWithPropertiesin interfaceEmbeddedActiveMQOperations
-
createMessageWithProperties
public org.apache.activemq.artemis.api.core.client.ClientMessage createMessageWithProperties(byte[] body, Map<String,Object> properties)- Specified by:
createMessageWithPropertiesin interfaceEmbeddedActiveMQOperations
-
createMessageWithProperties
public org.apache.activemq.artemis.api.core.client.ClientMessage createMessageWithProperties(String body, Map<String,Object> properties)
- Specified by:
createMessageWithPropertiesin interfaceEmbeddedActiveMQOperations
-
sendMessage
public void sendMessage(String address, org.apache.activemq.artemis.api.core.client.ClientMessage message)
- Specified by:
sendMessagein interfaceEmbeddedActiveMQOperations
-
sendMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessage(String address, byte[] body)
- Specified by:
sendMessagein interfaceEmbeddedActiveMQOperations
-
sendMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessage(String address, String body)
- Specified by:
sendMessagein interfaceEmbeddedActiveMQOperations
-
sendMessageWithProperties
public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessageWithProperties(String address, Map<String,Object> properties)
- Specified by:
sendMessageWithPropertiesin interfaceEmbeddedActiveMQOperations
-
sendMessageWithProperties
public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessageWithProperties(String address, byte[] body, Map<String,Object> properties)
- Specified by:
sendMessageWithPropertiesin interfaceEmbeddedActiveMQOperations
-
sendMessageWithProperties
public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessageWithProperties(String address, String body, Map<String,Object> properties)
- Specified by:
sendMessageWithPropertiesin interfaceEmbeddedActiveMQOperations
-
sendMessage
public void sendMessage(SimpleString address, org.apache.activemq.artemis.api.core.client.ClientMessage message)
- Specified by:
sendMessagein interfaceEmbeddedActiveMQOperations
-
sendMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessage(SimpleString address, byte[] body)
- Specified by:
sendMessagein interfaceEmbeddedActiveMQOperations
-
sendMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessage(SimpleString address, String body)
- Specified by:
sendMessagein interfaceEmbeddedActiveMQOperations
-
sendMessageWithProperties
public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessageWithProperties(SimpleString address, Map<String,Object> properties)
- Specified by:
sendMessageWithPropertiesin interfaceEmbeddedActiveMQOperations
-
sendMessageWithProperties
public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessageWithProperties(SimpleString address, byte[] body, Map<String,Object> properties)
- Specified by:
sendMessageWithPropertiesin interfaceEmbeddedActiveMQOperations
-
sendMessageWithProperties
public org.apache.activemq.artemis.api.core.client.ClientMessage sendMessageWithProperties(SimpleString address, String body, Map<String,Object> properties)
- Specified by:
sendMessageWithPropertiesin interfaceEmbeddedActiveMQOperations
-
receiveMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage receiveMessage(String queueName)
- Specified by:
receiveMessagein interfaceEmbeddedActiveMQOperations
-
receiveMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage receiveMessage(String queueName, long timeout)
- Specified by:
receiveMessagein interfaceEmbeddedActiveMQOperations
-
receiveMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage receiveMessage(SimpleString queueName)
- Specified by:
receiveMessagein interfaceEmbeddedActiveMQOperations
-
receiveMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage receiveMessage(SimpleString queueName, long timeout)
- Specified by:
receiveMessagein interfaceEmbeddedActiveMQOperations
-
browseMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage browseMessage(String queueName)
- Specified by:
browseMessagein interfaceEmbeddedActiveMQOperations
-
browseMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage browseMessage(String queueName, long timeout)
- Specified by:
browseMessagein interfaceEmbeddedActiveMQOperations
-
browseMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage browseMessage(SimpleString queueName)
- Specified by:
browseMessagein interfaceEmbeddedActiveMQOperations
-
browseMessage
public org.apache.activemq.artemis.api.core.client.ClientMessage browseMessage(SimpleString queueName, long timeout)
- Specified by:
browseMessagein interfaceEmbeddedActiveMQOperations
-
-