Class ActiveMQConsumerResource

java.lang.Object
org.junit.rules.ExternalResource
org.apache.activemq.artemis.junit.ActiveMQConsumerResource
All Implemented Interfaces:
ActiveMQConsumerOperations, org.junit.rules.TestRule

public class ActiveMQConsumerResource extends org.junit.rules.ExternalResource implements ActiveMQConsumerOperations
A JUnit Rule that embeds an ActiveMQ Artemis ClientConsumer 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 a ClientConsumer, which can then be used to consume messages from an ActiveMQ Artemis server.

 public class SimpleTest {
     @Rule
     public ActiveMQConsumerResource client = new ActiveMQProducerResource( "vm://0", "test.queue" );

     @Test
     public void testSomething() throws Exception {
         // Use the embedded client here
         ClientMessage message = client.receiveMessage();
     }
 }