How to test existing camel endpoints with mock?

Viewed 5150

Im currently working with Camel's mock component and i would like to test it on an existing routes. Basically i want to retain the existing routes defined in the app, but inject a few mocks during test, to verify or at least peek on the current exchange contents.

Based on the docs and from the Apache Camel Cookbook. I've tried to use @MockEndpoints

Here's the route builder

@Component
public class MockedRouteStub extends RouteBuilder {

    private static final Logger LOGGER = LoggerFactory.getLogger(MockedRouteStub.class);

    @Override
    public void configure() throws Exception {
        from("direct:stub")
            .choice()
                .when().simple("${body} contains 'Camel'")
                    .setHeader("verified").constant(true)
                    .to("direct:foo")
                .otherwise()
                    .to("direct:bar")
                .end();

        from("direct:foo")
            .process(e -> LOGGER.info("foo {}", e.getIn().getBody()));

        from("direct:bar")
            .process(e -> LOGGER.info("bar {}", e.getIn().getBody()));

    }

}

Here's my test (currently its a springboot project):

@RunWith(SpringRunner.class)
@SpringBootTest
@MockEndpoints
public class MockedRouteStubTest {

    @Autowired
    private ProducerTemplate producerTemplate;

    @EndpointInject(uri = "mock:direct:foo")
    private MockEndpoint mockCamel;

    @Test
    public void test() throws InterruptedException {
        String body = "Camel";
        mockCamel.expectedMessageCount(1);

        producerTemplate.sendBody("direct:stub", body);

        mockCamel.assertIsSatisfied();
    }

}

message count is 0 and it looks more like @MockEndpoints is not triggered. Also, logs indicate that the log is triggered

route.MockedRouteStub    : foo Camel

An alternative i've tried is to use an advice:

...
        @Autowired
        private CamelContext context;

        @Before
        public void setup() throws Exception {
            context.getRouteDefinitions().get(0).adviceWith(context, new AdviceWithRouteBuilder() {

                @Override
                public void configure() throws Exception {
                    mockEndpoints();
                }
            });
        }

The startup logs indicate that advice is in place:

c.i.InterceptSendToMockEndpointStrategy : Adviced endpoint [direct://stub] with mock endpoint [mock:direct:stub]

But still my test fails with the message count = 0.

1 Answers
Related