如何在Camel测试中模拟AMQP消费者？

Question

说我有以下路线：

from(rabbitMQUri)
    .to(myCustomerProcessor)
    .choice()
        .when(shouldGotoA)
            .to(fizz)
        .when(shouldGotoB)
            .to(buzz)
        .otherwise()
            .to(foo);

让我们假设MyCustomProcessor根据RabbitMQ使用的消息调整ShouldGotoa和ShouldGotob。

我想对3个场景进行单元测试：

null

我的问题是：如何模拟/存根RabbitMQendpoint，以便路由在生产中正常执行，但不必实际将测试连接到RabbitMQ服务器？我需要某种“模拟信息”制作人。

一个代码示例或代码片段将非常有帮助，非常感谢！

Answer 1

这是组合一个合适的测试的一种方法。

首先定义一个空的Camel上下文，其中只有一个ProducerTemplate：

<camel:camelContext id="camelContext">
   <camel:template id="producerTemplate" />
</camel:camelContext>

这样做是为了当我执行测试时，我可以控制哪些路由实际上开始，因为我不希望所有的路由在测试期间开始。

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = { "classpath:/spring/spring-test-camel.xml" })
public class MyTest {

    @Autowired
    private ProducerTemplate producerTemplate;

    @Autowired
    private CamelContext camelContext;

camelContext.removeComponent("jms");
camelContext.addComponent("jms", this.camelContext.getComponent("seda"));
camelContext.addRoutes(this.documentBatchRouting);

producerTemplate.sendBody("jms:MyQueue", 2);

需要注意的两点是：

>

您的事务边界可能会改变，特别是如果您用直接组件替换JMS队列

如果您要测试几条路由，那么在测试结束时必须小心地将该路由从Camel上下文中移除。