如何解决使用嵌入式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)控制台上显示两次“消息发送成功”。但是,当我尝试从队列中读取时,断言失败(=未找到消息)。我的会话未完成。
我在这里想念什么?
解决方法
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。