骆驼净消费者总是发送即时响应，即使路由未完成

Question

我正在使用apache camel 3.8，并试图制作一个简单的tcp服务器，将请求消息发送回客户端（我使用的客户端是PacketSender）。
问题是，如果process（）方法花费太长时间，15毫秒后netty会在后台返回一个空响应，即使process（）仍在Thread.sleep中。如果我不让方法（线程）Hibernate，响应会立即与接收到的内容一起发送。

我该如何管理它，netty正在等待我完成我的进程并发送我在交换消息正文中设置的响应？

以下是我使用的路线：

fromF("netty:tcp://%s:%d?sync=true&synchronous=true&disconnectOnNoReply=false&connectTimeout=100000", host, receivePort)
    .bean(HL7Request.class, "process", BeanScope.Request);

bean进程方法如下所示，为了模拟长时间执行的进程，我使用了Thread.sleep：

public void process(Exchange exchange) throws Exception {

        try {
            CamelContext context = exchange.getContext();
            exchange.setException(null);

            Thread.sleep(5000); // <-- Here the method stopps for 5 seconds but the response is sent by netty anyway
            String content = exchange.getMessage().getBody(String.class);
            System.out.println(content);
        }
        catch (Exception e) {
            exchange.setException(e);
        }
    }

PacketSender收到空响应

谢谢问候弗洛里安

Answer 1

我认为这是数据包发送软件的问题。它完美地使用命令行远程登录。

有关该错误的更多详细信息