使用嵌入式Artemis进行单元测试JMS 2.0

问题描述

我尝试测试使用JMS 2.0 API消耗JMS消息的应用程序。

为降低测试的复杂性，我在测试内使用MessageProducer发送一条消息，并尝试在同一会话上使用MessageConsumer读回该消息。

我使用了一个兼容JMS 2.0的嵌入式ActiveMQ-Artemis 2.5.0实例。

package be.attle;

import javax.jms.CompletionListener;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;

import org.apache.activemq.artemis.api.core.client.ActiveMQClient;
import org.apache.activemq.artemis.api.core.client.ServerLocator;
import org.apache.activemq.artemis.api.jms.ActiveMQJMSClient;
import org.apache.activemq.artemis.jms.client.ActiveMQJMSConnectionFactory;
import org.apache.activemq.artemis.junit.EmbeddedActiveMQResource;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Rule;
import org.junit.Test;
import org.mockito.MockitoAnnotations;

public class ActiveMQTest {
    @Rule
    public EmbeddedActiveMQResource resource = new EmbeddedActiveMQResource();

    private Queue queue;
    
    private ConnectionFactory factory;
    private Session session;
    
    @Before
    public void setUp() throws Exception
    {
        MockitoAnnotations.initMocks(this);
        ServerLocator serverLocator =  ActiveMQClient.createServerLocator("vm://0");
        factory=new ActiveMQJMSConnectionFactory(serverLocator);
        queue = ActiveMQJMSClient.createQueue(AsyncJobConst.QUEUE_NAME);
        Connection conn=factory.createConnection();
        session=conn.createSession(false,Session.CLIENT_ACKNOWLEDGE);
    }
    
    @Test
    public void easyPeasy() throws JMSException
    {
        
        MessageProducer producer=session.createProducer(queue);
        CompletionListener listener=new CompletionListener() {
            
            @Override
            public void onException(Message message,Exception exception) {
                System.err.println("message send failed:"+exception);
            }
            
            @Override
            public void onCompletion(Message message) {
                System.out.println("message send successfully");                
            }
        };
        
        producer.send(session.createTextMessage("testBody1"),listener);
        producer.send(session.createTextMessage("testBody2"),listener);
        // (1)
        // let's try the consume the first message
        MessageConsumer consumer=session.createConsumer(queue);
        Message message=consumer.receiveNoWait();
        Assert.assertNotNull(message);
    }
}

在（1）控制台上显示两次“消息发送成功”。但是，当我尝试从队列中读取时，断言失败（=未找到消息）。我的会话未完成。

我在这里想念什么？

解决方法

需要在连接上调用start()才能开始连接的传入消息传递。您可以找到一个简单的示例here。