Camel单元测试总是失败，我无法解释为什么期望是0或者如何正确地断言期望

Question

我有这个带有Apache Camel的Restendpoint来查找来自不同来源的一些值，首先我验证请求，然后根据路径我去不同的路由：

restConfiguration()
    .component("servlet")
    .bindingMode(RestBindingMode.json)
...

rest("/lookup/{path}")
    .consumes(MediaType.APPLICATION_JSON_VALUE)
    .produces(MediaType.APPLICATION_JSON_VALUE)
    .post().type(LookupRequest.class).outType(LookupResponse.class)
    .to("direct:validate-request")

from("direct:validate-request")
    .routeId(Constants.ROUTE_VALIDATE_REQUEST)
    .to("bean-validator://x")
    .process(exchange ->
        exchange.getIn().setHeader("lookupType", env.getProperty("lookup.path." + exchange.getIn().getHeader("path", String.class)))
    )
    .to("bean:lookupValidationService?method=validate(${body}, ${header.lookupType})")
    .toD("direct:db-lookup-${header.lookupType}");

from("direct:db-lookup-customer")
    .routeId(Constants.ROUTE_CUSTOMER_LOOKUP)
    .log(LoggingLevel.DEBUG, CamelRouter.CAMEL_BODY)
        ...
    .to("sql:{{lookup.queries.customer}}?placeholder=~&usePlaceholder=true")
    .process(new SqlQueryResultProcessor())
        ...
    .endRest();

这是我测试路线的一次尝试：

@ActiveProfiles("test")
@CamelSpringBootTest
@SpringBootTest(classes = LookupServiceApplication.class)
@MockEndpointsAndSkip("log:.*")
@UseAdviceWith
class CameltestingApplicationTests {

    @Autowired CamelContext camelContext;
    @Autowired ProducerTemplate producerTemplate;

    @EndpointInject("mock:direct:db-lookup-customer")
    MockEndpoint customerMock;

    static List<Map<String, Object>> results = new ArrayList<Map<String, Object>>() {{
        add(new HashMap<String, Object>() {{
            put("customerName", "Test customer");
        }});
    }};

    @BeforeEach
    public void before() throws Exception {
        camelContext.setTracing(true);
        AdviceWith.adviceWith(camelContext, Constants.ROUTE_CUSTOMER_LOOKUP, routeBuilder -> {
            routeBuilder.interceptSendToEndpoint("sql:*").skipSendToOriginalEndpoint().process(e -> e.getIn().setBody(results));
        });
    }
    @Test
    public void testReceive() throws Exception {
        camelContext.start();
        // Expect:
        customerMock.expectedMessageCount(1);
        // And: the process to set the header
        customerMock.expectedHeaderReceived("lookupType", "customer.info");

        Map<String, Object> headers = new HashMap<>();
        headers.put("path", "customer.info");
        Map<String, Object> keywords = new HashMap<>();
        keywords.put("customerNumber", 1234678);
        LookupRequest request = new LookupRequest();
        request.setKeywords(keywords);

        // When we send the message
        producerTemplate.sendBodyAndHeaders("direct:validate-request", request, headers);
        // Everything is satisfied.
        Assert.assertNotNull(camelContext.hasEndpoint("direct:db-lookup-customer"));
        customerMock.assertIsSatisfied();
    }
}

这是日志:

2021-07-12 12:10:13.604  INFO 660 --- [           main] o.a.c.i.e.AbstractCamelContext           : Apache Camel 3.11.0 (Lookup service) started in 1s246ms (build:160ms init:1s7ms start:79ms)
2021-07-12 12:10:13.623  INFO 660 --- [           main] o.a.c.Tracing                            : *--> [validate    ] [from[direct:validate-request]    ] Exchange[Id: 32F8D8FB9A7CF84-0000000000000000, BodyType: com.odfl.freight.lookupservice.model.LookupRequest, Body: LookupRequest(keywords={customerNumber=1234678})]
2021-07-12 12:10:13.624  INFO 660 --- [           main] o.a.c.Tracing                            :      [validate    ] [bean-validator://x               ] Exchange[Id: 32F8D8FB9A7CF84-0000000000000000, BodyType: com.odfl.freight.lookupservice.model.LookupRequest, Body: LookupRequest(keywords={customerNumber=1234678})]
2021-07-12 12:10:13.727  INFO 660 --- [           main] o.a.c.Tracing                            :      [validate    ] [Processor@0x166ddfb7             ] Exchange[Id: 32F8D8FB9A7CF84-0000000000000000, BodyType: com.odfl.freight.lookupservice.model.LookupRequest, Body: LookupRequest(keywords={customerNumber=1234678})]
2021-07-12 12:10:13.728  INFO 660 --- [           main] o.a.c.Tracing                            :      [validate    ] [bean:lookupValidationService?meth] Exchange[Id: 32F8D8FB9A7CF84-0000000000000000, BodyType: com.odfl.freight.lookupservice.model.LookupRequest, Body: LookupRequest(keywords={customerNumber=1234678})]
2021-07-12 12:10:13.733  INFO 660 --- [           main] o.a.c.Tracing                            :      [validate    ] [direct:db-lookup-${header.lookupT] Exchange[Id: 32F8D8FB9A7CF84-0000000000000000, BodyType: com.odfl.freight.lookupservice.model.LookupRequest, Body: LookupRequest(keywords={customerNumber=1234678})]
2021-07-12 12:10:13.739  INFO 660 --- [           main] o.a.c.Tracing                            : ---> [customer    ] [from[direct:db-lookup-customer]  ] Exchange[Id: 32F8D8FB9A7CF84-0000000000000000, BodyType: com.odfl.freight.lookupservice.model.LookupRequest, Body: LookupRequest(keywords={customerNumber=1234678})]
2021-07-12 12:10:13.740  INFO 660 --- [           main] o.a.c.Tracing                            :      [customer    ] [log                              ] Exchange[Id: 32F8D8FB9A7CF84-0000000000000000, BodyType: com.odfl.freight.lookupservice.model.LookupRequest, Body: LookupRequest(keywords={customerNumber=1234678})]
2021-07-12 12:10:13.740  INFO 660 --- [           main] o.a.c.Tracing                            :      [customer    ] [setHeader[customerNumber]        ] Exchange[Id: 32F8D8FB9A7CF84-0000000000000000, BodyType: com.odfl.freight.lookupservice.model.LookupRequest, Body: LookupRequest(keywords={customerNumber=1234678})]
2021-07-12 12:10:13.891  INFO 660 --- [           main] o.a.c.Tracing                            :      [customer    ] [sql:{{lookup.queries.customer}}?p] Exchange[Id: 32F8D8FB9A7CF84-0000000000000000, BodyType: com.odfl.freight.lookupservice.model.LookupRequest, Body: LookupRequest(keywords={customerNumber=1234678})]
2021-07-12 12:10:13.892  INFO 660 --- [           main] o.a.c.Tracing                            :      [customer    ] [Processor@0x1feb586d             ] Exchange[Id: 32F8D8FB9A7CF84-0000000000000000, BodyType: com.odfl.freight.lookupservice.model.LookupRequest, Body: LookupRequest(keywords={customerNumber=1234678})]
2021-07-12 12:10:13.895  INFO 660 --- [           main] o.a.c.Tracing                            :      [customer    ] [Processor@0x34695b23             ] Exchange[Id: 32F8D8FB9A7CF84-0000000000000000, BodyType: null, Body: [{customerName=Test customer}]]
2021-07-12 12:10:13.896  INFO 660 --- [           main] o.a.c.Tracing                            :      [customer    ] [log                              ] Exchange[Id: 32F8D8FB9A7CF84-0000000000000000, BodyType: com.odfl.freight.lookupservice.model.LookupResponse, Body: LookupResponse(ok=true, errorMessage=null, results=[{customerName=Test customer}])]
2021-07-12 12:10:13.896  INFO 660 --- [           main] o.a.c.Tracing                            : <--- [customer    ] [from[direct://db-lookup-customer]] Exchange[Id: 32F8D8FB9A7CF84-0000000000000000, BodyType: com.odfl.freight.lookupservice.model.LookupResponse, Body: LookupResponse(ok=true, errorMessage=null, results=[{customerName=Test customer}])]
2021-07-12 12:10:13.897  INFO 660 --- [           main] o.a.c.Tracing                            : *<-- [validate    ] [from[direct://validate-request]  ] Exchange[Id: 32F8D8FB9A7CF84-0000000000000000, BodyType: com.odfl.freight.lookupservice.model.LookupResponse, Body: LookupResponse(ok=true, errorMessage=null, results=[{customerName=Test customer}])]
2021-07-12 12:10:13.900  INFO 660 --- [           main] o.a.c.c.m.MockEndpoint                   : Asserting: mock://direct:db-lookup-customer is satisfied

...

java.lang.AssertionError: mock://direct:db-lookup-customer Received message count 0, expected at least 1

    at org.apache.camel.component.mock.MockEndpoint.fail(MockEndpoint.java:1790)
    at org.apache.camel.component.mock.MockEndpoint.assertTrue(MockEndpoint.java:1773)

我是测试 Apache Camel 路由的新手，有人可以帮助我了解问题在哪里或如何验证输出，因为您可以看到交换对象主体在那里并通过。我已经尝试了一些方法来模拟这个endpoint，但似乎没有任何效果，我的想法也没了。

Answer 1

您只使用@MockEndpointsAndSkip（“log:.*”）模拟了logendpoint，并将customerMock注入为mock:direct:dblookupcustomer，但如果它不在路由中，它如何接收消息
我认为您所需要的只是以某种方式模拟您的direct:db查找客户，例如在adviceWith中或使用注释