Spring JMS集成单元测试在队列上留下消息

我使用Spring 4.3.5.Release和ActiveMQ 5.14.3来处理消息队列。Spring JMS集成单元测试在队列上留下消息

下面是从应用程序上下文文件我的定义：

<!-- Activemq connection factory --> 
<bean id="amqConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> 
    <!-- brokerURL, You may have different IP or port --> 
    <constructor-arg index="0" value="${message.broker.url}" /> 
</bean> 

<!-- Pooled Spring connection factory --> 
<bean id="jmsConnectionFactory" 
    class="org.springframework.jms.connection.CachingConnectionFactory"> 
    <constructor-arg ref="amqConnectionFactory" /> 
</bean> 

<!-- ======================================================= --> 
<!-- JMS Send, define default destination and JmsTemplate --> 
<!-- ======================================================= --> 
<!-- Default Destination Queue Definition --> 
<bean id="defaultDestination" class="org.apache.activemq.command.ActiveMQQueue"> 
    <!-- name of the queue --> 
    <constructor-arg index="0" value="${default.message.queue}" /> 
</bean> 

<bean id="jmsDestinationResolver" class="org.springframework.jms.support.destination.DynamicDestinationResolver"/> 

<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> 
    <property name="connectionFactory" ref="jmsConnectionFactory"/> 
    <property name="defaultDestination" ref="defaultDestination" /> 
    <property name="destinationResolver" ref="jmsDestinationResolver"/> 
    <property name="pubSubDomain" value="${pub.sub.domain}"/> 
    <property name="receiveTimeout" value="${receive.timeout}"/> 
</bean>

这里是在默认队列创建消息代码：

public boolean sendResponse(final MyObjectDTO myObject) { 
    boolean success = false; 
    this.jmsTemplate.convertAndSend(ebvResponse); 
    success = true; 
    return success; 
}

这里是我的单元测试：

@RunWith(SpringJUnit4ClassRunner.class) 
@ContextConfiguration(locations = 
{ "classpath:/spring/my-platform-services-context.xml" }) 
@Transactional 
public class MessageUtilTest extends TestCase { 

    @Autowired 
    private MessageUtil messageUtil; 

    @Test 
    public void testConvertSendMessageToDefault() throws JsonParseException, JsonMappingException, IOException { 
     MyObjectDTO myObject = new ManualCoverageDTO(); 
     myObject.setMessage(message); 
     boolean success = messageUtil.sendResponse(myObject); 
     assertEquals(true, success); 
    } 
}

这个测试效果很好，并且一条消息正确地进入队列！

我期望测试结束时，因为单元测试是Transactional，消息会从队列中回滚，但似乎不是。

我知道这是一个“集成”测试，因为它实际上是触摸ActiveMQ服务器并在队列中放置消息。

那么，我怎样才能使这个真正的事务性，使我刚刚放在队列中的消息真的回滚时，我必须手动告诉这个测试回滚？

我已经对数据库进行了数百次“集成”单元测试，并且在每次插入，更新或删除一次测试后，以及测试结束后，数据库将回滚到它所处的状态在测试之前，我希望我的消息队列或主题发生同样的事情。

任何帮助，这将是伟大的。谢谢！

来源

2017-02-24 tjholmes66

您需要将sessionTransacted设置为JmsTemplate至true。

但是，请记住，除非您提交，否则您将无法在任何地方收到测试消息。

来源

2017-02-24 15:54:15

Spring JMS集成单元测试在队列上留下消息

回答

相关问题