问服务器模式下的Apache Camel netty4生产者

EN

public class NettyEnrich extends CamelTestSupport {

    @Override
    protected RoutesBuilder createRouteBuilder() throws Exception {
        return new RouteBuilder() {
            @Override
            public void configure() throws Exception {
                from("direct:in")
                        .pollEnrich("netty4:tcp://127.0.0.1:12345")
                        .to("mock:out");
            }
        };
    }

    @Test
    public void test() throws Exception{
        MockEndpoint mockEndpoint = getMockEndpoint("mock:out");
        mockEndpoint.setExpectedCount(1);

        template.asyncSendBody("direct:in",""); //direct:in is now waiting for connection from netty client
        template.sendBody("netty4:tcp://127.0.0.1:12345", "Hello from TCP"); //Initialize connection to resume direct:in

        mockEndpoint.assertIsSatisfied();
        Assert.assertEquals("Hello from TCP", mockEndpoint.getExchanges().get(0).getIn().getBody());
    }
}