使用apachecamel进行单元测试

Question

我想测试以下骆驼路线。我在网上找到的所有例子都有以文件开头的路由，在我的例子中，我有一个Springbean方法，每隔几分钟就会被调用一次，最后消息被转换并移动到jms以及审计目录。

我对这条路线的写测试毫无头绪。目前我在测试用例中所拥有的是Mockito。when（tradeService.searchTransaction（））。然后返回（带有SingleTransaction的数据）

from("quartz2://tsTimer?cron=0/20+*+8-18+?+*+MON,TUE,WED,THU,FRI+*")
.bean(TradeService.class)
.marshal()
.jacksonxml(true)
.to("jms:queue:out-test")
.to("file:data/test/audit")
.end();




Answer 1

@点头的手谢谢你的提示，我完全走错了方向。读完你的答案后，我能够写基本的测试，从这一点上，我想我可以把它向前推进。

非常感谢您的时间，但是我看到根据我的路线，它应该将一个XML文件放到审计目录中，而这并没有发生。

看起来中间步骤也被嘲笑了，我没有指定任何东西。

InterceptSendToMockEndpointStrategy - Adviced endpoint [xslt://trans.xslt] with mock endpoint [mock:xslt:trans.xslt]
INFO  o.a.c.i.InterceptSendToMockEndpointStrategy - Adviced endpoint [file://test/data/audit/?fileName=%24%7Bheader.outFileName%7D] with mock endpoint [mock:file:test/data/audit/]
INFO  o.a.camel.spring.SpringCamelContext - StreamCaching is not in use. If using streams then its recommended to enable stream caching. See more details at http://camel.apache.org/stream-caching.html

特劳特。JAVA

    @Override
    public void configure() throws Exception {
        logger.info("TradePublisherRoute.configure() : trade-publisher started configuring camel route.");

        from("{{trade-publisher.sourceEndpoint}}")
        .doTry()
            .bean(tradeService)
            .process(new Processor() {
                @Override
                public void process(Exchange exchange) throws Exception {
                    String dateStr = Constant.dateFormatForFileName.format(new Date());
                    logger.info("this is getting executed : " + dateStr);
                    exchange.setProperty(Constant.KEY_INCOMING_XML_FILE_NAME, "REQ-" + dateStr + Constant.AUDIT_FILE_EXTENSION);
                    exchange.setProperty(Constant.KEY_OUTGOING_XML_FILE_NAME, "RESP-" + dateStr + Constant.AUDIT_FILE_EXTENSION);
                }
            })
            .marshal()
            .jacksonxml(true)
            .wireTap("{{trade-publisher.requestAuditDir}}" + "${header.inFileName}")
            .to("{{trade-publisher.xsltFile}}")
            .to("{{trade-publisher.outboundQueue}}")
            .to("{{trade-publisher.responseAuditDir}}" + "${header.outFileName}")
            .bean(txnService, "markSuccess")
        .endDoTry()
        .doCatch(Exception.class)
            .bean(txnService, "markFailure")
            .log(LoggingLevel.ERROR, "EXCEPTION: ${exception.stacktrace}")
        .end();

TradePublisherRouteTest。JAVA

@ActiveProfiles("test")
@RunWith(CamelSpringBootRunner.class)
@SpringBootTest(classes = TradePublisherApplication.class)
@MockEndpoints
public class TradePublisherRouteTest {

    @EndpointInject(uri = "{{trade-publisher.outboundQueue}}")
    private MockEndpoint mockQueue;

    @EndpointInject(uri = "{{trade-publisher.sourceEndpoint}}")
    private ProducerTemplate producerTemplate;

    @MockBean
    TradeService tradeService;

    private List<Transaction> transactions = new ArrayList<>();

    @BeforeClass
    public static void beforeClass() {

    }

    @Before
    public void before() throws Exception {
        Transaction txn = new Transaction("TEST001", "C001", "100", "JPM", new BigDecimal(100.50), new Date(), new Date(), 1000, "P");
        transactions.add(txn);

    }

    @Test
    public void testRouteConfiguration() throws Exception {
        Mockito.when(tradeService.searchTransaction()).thenReturn(new Data(transactions));
        producerTemplate.sendBody(transactions);
        mockQueue.expectedMessageCount(1);
        mockQueue.assertIsSatisfied(2000);
    }

如果我做错了，请纠正我！

Answer 2

使用ApacheCamel和Spring Boot进行测试非常简单。

只需执行以下操作（下面的示例是一个抽象示例，只是为了给您一个如何执行的提示）：

使用Spring Boot注释来配置测试类。

@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.NONE)
@RunWith(SpringRunner.class)
public class MyRouteTest {
    @EndpointInject(uri = "{{sourceEndpoint}}")
    private ProducerTemplate sourceEndpoint;
    ....
    public void test() {
        // send your body to the endpoint. See other provided methods too.
        sourceEndpoint.sendBody([your input]);
    }
}

在src/test/application.properties中：配置您的Camel-Endpoint，如源和目标：

sourceEndpoint=direct:myTestSource

在使用spring boot时，最好不要直接在路由中硬连接起始endpoint，而是使用应用程序。属性。这样，模拟endpoint进行单元测试就更容易了，因为您可以在不更改源代码的情况下更改为direct-组件。

这意味着，您应该编写：from（“{sourceEndpoint}”）

并在您的application.properties中配置ourceEndpoint：ourceEndpoint=QUITZ2：//tsTimer？0/20 * 8-18*周一，周二，周三，周四，周五*

这样你也可以在不同的情况下使用你的路线。

有关如何使用spring boot进行测试的良好文档可以在以下位置找到：https://docs.spring.io/spring-boot/docs/current/reference/html/boot-features-testing.html

阿帕奇骆驼：http://camel.apache.org/testing.html