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

Question

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

为了降低测试的复杂性，我在测试中使用 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) 处，控制台显示两次“消息发送成功”。但是，当我尝试从队列中读取时，断言失败（=未找到消息）。我的会话未被处理。

我在这里错过了什么？

Answer 1

调用 start() on the connection is required to start the connection's delivery of incoming messages. You can find a simple example here。

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

Unit test JMS 2.0 using embedded Artemis

java

junit

jms

activemq-artemis