用骆驼和石英的特定顺序安排路线2

Question

我想用Apache Camel和Quartz2按spceific顺序设计路线。我定义了一个上下文，添加了两条路由：

public static void main(String args[]) throws Exception {
    CamelContext context = new DefaultCamelContext();
    context.addRoutes(new RouteBuilder() {
        @Override
        public void configure() {

            from("quartz2://myGroup/myTimerName?trigger.repeatInterval=2000&trigger.repeatCount=5").startupOrder(1).setBody().simple("Current time is "+new SimpleDateFormat("HH:mm:ss").format(new Date())).to("stream:out");
            //from("quartz2://myGroup/myTimerName?trigger.repeatInterval=2000&trigger.repeatCount=5").setBody().simple("Current time is ${header.firedTime}").to("stream:out");

        }
    });

    context.addRoutes(new RouteBuilder() {
        @Override
        public void configure() {

            from("quartz2://myGroup/myTimerName?trigger.repeatInterval=2000&trigger.repeatCount=5").startupOrder(2).setBody().simple("Current time is "+new SimpleDateFormat("HH:mm:ss").format(new Date())).to("file:C:\\Users\\milioli\\Documents\\NetBeansProjects\\CamelWithQuartz\\data\\out.txt");
        }
    });

    context.startAllRoutes();
    Thread.sleep(10000);
    context.stop();

}

代码构建和运行，但我没有来自控制台的反馈，我期待订单1的路由结果。此外，顺序为2的路由不会写入作为参数传递的文件。每条路线，采取单独正确运行。有人能帮帮我吗？

Answer 1

我建议您在开始编写代码之前创建单元测试，甚至将它们用于Camel路由的开发（只要您可以模拟endpoint）。

下面的测试表明，如果Quartz调度器的名称不同，则可以使用两个Quartz调度器：

package org.ruffp.camel.quartz;

import org.apache.camel.EndpointInject;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.junit4.CamelTestSupport;
import org.junit.Test;

public class QuartzEndpointTest extends CamelTestSupport {

    @EndpointInject(uri = "mock:DESTINATION")
    private MockEndpoint mockDestination;

    @Test
    public void testQuartz() throws Exception {
        resetMocks();
        mockDestination.expectedMessageCount(3);
        Thread.sleep(10000);
        assertMockEndpointsSatisfied();
    }

    @Override
    protected RouteBuilder createRouteBuilder() throws Exception {

        return new RouteBuilder() {
            @Override
            public void configure() throws Exception {

                //@formatter:off
                from("quartz2://myGroup/myTimerNameOne?trigger.repeatInterval=100&trigger.repeatCount=1")
                    .setProperty("test").constant("This is the job 1")
                    .to(mockDestination);

                from("quartz2://myGroup/myTimerNameTwo?trigger.repeatInterval=100&trigger.repeatCount=0")
                .setProperty("test").constant("This is the job 2")
                .to(mockDestination);

                //@formatter:on
            }
        };
    }
}

如果将两者的名称相同（例如MyTimerName)，测试将不会通过，但是路由定义不会引发任何错误/异常。