这是我的简单路线:
@Override
public void configure() {
onException(Exception.class)
.handled(true)
.process(exchange -> {
Exception exception = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, Exception.class);
log.error(logFormat.error(exchange, exception, exception.getMessage()));
exchange.getIn().setBody(exception.getMessage());
exchange.getIn().setHeader(Exchange.HTTP_RESPONSE_CODE, HttpStatus.SC_INTERNAL_SERVER_ERROR);
});
onException(HttpOperationFailedException.class)
.handled(true)
.to("direct:handleHttpOperationFailed");
from("direct:myRoute")
.routeId("myRoute")
.log("Route start: myRoute")
.id("startStep")
.process(
exchange -> log.info("Doing some processing")
)
.id("processingStep")
.end();
}
现在我想编写一些测试:
- 异常处理案例 - 在“processingStep”之后抛出异常并在 onException 中处理
- 积极场景 - 所有流程均顺利进行
这就是我所做的......
我的测试注释:
@RunWith(CamelSpringBootRunner.class)
@UseAdviceWith
@SpringBootTest(classes = Application.class, webEnvironment = SpringBootTest.WebEnvironment.DEFINED_PORT)
public class StarlingFpsInboundWebhookIT {
...
}
我的两个测试用例:
- 有异常情况 - 这里我使用adviceWith在“processingStep”之后抛出异常:
@Test
public void exceptionScenario() throws Exception {
// Given
context.getRouteDefinition("myRoute").adviceWith(context, new AdviceWithRouteBuilder() {
@Override
public void configure() {
weaveById("processingStep").after()
.process(exchange -> {
throw ExceptionFixtures.createSimpleException();
})
.id("exceptionThrowStep");
}
});
context.start();
String requestBody = ResourcesHelper.read(this.getClass(), "/data/input/request.json");
// When
template.send("direct:myRoute", camelExchange -> {...});
}
- 成功案例 - 这里我需要删除之前创建的“exceptionThrowStep”以免抛出异常:
@Test
public void successScenario() throws Exception {
// Given
context.getRouteDefinition("myRoute").adviceWith(context, new AdviceWithRouteBuilder() {
@Override
public void configure() {
weaveById("exceptionThrowStep").remove();
}
});
context.start();
String requestBody = ResourcesHelper.read(this.getClass(), "/data/input/request.json");
// When
template.send("direct:myRoute", camelExchange -> {...});
}
当我运行这些测试时(第一个异常然后成功的场景),我在第二个测试中遇到异常:
org.apache.camel.FailedToCreateRouteException:
Failed to create route myRoute at:
>>> pipeline -> [[]] <<<
in route: Route(myRoute)[[From[direct:myRoute]...
because of Definition has no children on pipeline -> [[]]
为什么会出现这个异常?我读过很多文章,但没有发现任何关于这个案例的宝贵信息:( 有趣的是-当在adviceWith的第二次测试中我使用replace()而不是remove()时,一切正常......
我的问题是:
- 在路由中测试异常处理是一种好方法吗?
- 我们可以在测试之间重置路由定义来避免我的方法吗?
最佳答案
最后我从你的两个问题开始:
- 是的,最好也测试路线的错误路径,而不仅仅是快乐路径
- 是的,您可以并且应该在测试之间重置路由定义。由于您运行
SpringBootTest
,您可以使用DirtiesContext
annotation 来完成此操作。 (Spring 测试框架的一部分)
示例:
@Test
@DirtiesContext
public void successScenario() throws Exception {
运行带注释的测试后,默认情况下会重置 Camel 路由。
您的测试不得依赖于特定顺序才能成功运行!这会导致测试结果不稳定并降低您对测试的信心。
一般来说,您的成功测试不需要任何路由修改,因为这是预期的处理路径。对于错误测试,您必须在路由中注入(inject)错误(就像使用adviceWith 一样)以模拟处理错误。
关于java - Apache Camel - 定义在管道上没有子项,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/62290721/