测试骆驼石英路线
testing camel quartz route
我尝试对 apache 骆驼路线进行 junit 测试。
像这样:
@RunWith(CamelSpringJUnit4ClassRunner.class)
@ContextConfiguration(
loader = CamelSpringDelegatingTestContextLoader.class
)
public class MyExportRouteBuilderIT extends CamelTestSupport {
@Test
public void test() {
// trigger and check the files made by route builder processor
}
@Override
protected RouteBuilder createRouteBuilder() throws Exception {
return new MyExportRouteBuilder();
}
}
构建器class是这样定义的
from("quartz2://exportJob?cron=" + cronTrigger)
.setHeader(FILE_NAME, expression(FILE_NAME_FORMAT))
.process(myExportRouteProcessor)
.marshal(new BindyCsvDataFormat(MyExportData.class))
.to("file:///destination);
'myExportRouteProcessor' class 只是从 JPA 存储库中获取一些数据并将结果放入路由。
我想要的是在测试 class 中触发此路由以检查整个过程是否正确完成。
当前,处理器未被解雇。我还应该做什么?
您可以直接使用 AdviceWithRouteBuilder#replaceFromWith 替换测试中的 quartz2 组件。
@Test
public void test() throws Exception{
//mock input route (replace quartz with direct)
context.getRouteDefinitions().get(0).adviceWith(context, new AdviceWithRouteBuilder() {
@Override
public void configure() throws Exception {
replaceFromWith("direct:triggerQuartz");
}
});
//trigger endpoint
sendBody("direct:triggerQuartz", null);
//do some assertions
}
我尝试对 apache 骆驼路线进行 junit 测试。 像这样:
@RunWith(CamelSpringJUnit4ClassRunner.class)
@ContextConfiguration(
loader = CamelSpringDelegatingTestContextLoader.class
)
public class MyExportRouteBuilderIT extends CamelTestSupport {
@Test
public void test() {
// trigger and check the files made by route builder processor
}
@Override
protected RouteBuilder createRouteBuilder() throws Exception {
return new MyExportRouteBuilder();
}
}
构建器class是这样定义的
from("quartz2://exportJob?cron=" + cronTrigger)
.setHeader(FILE_NAME, expression(FILE_NAME_FORMAT))
.process(myExportRouteProcessor)
.marshal(new BindyCsvDataFormat(MyExportData.class))
.to("file:///destination);
'myExportRouteProcessor' class 只是从 JPA 存储库中获取一些数据并将结果放入路由。 我想要的是在测试 class 中触发此路由以检查整个过程是否正确完成。 当前,处理器未被解雇。我还应该做什么?
您可以直接使用 AdviceWithRouteBuilder#replaceFromWith 替换测试中的 quartz2 组件。
@Test
public void test() throws Exception{
//mock input route (replace quartz with direct)
context.getRouteDefinitions().get(0).adviceWith(context, new AdviceWithRouteBuilder() {
@Override
public void configure() throws Exception {
replaceFromWith("direct:triggerQuartz");
}
});
//trigger endpoint
sendBody("direct:triggerQuartz", null);
//do some assertions
}