0

我在 Apache Camel 中使用 AHC-WS 组件连接到使用 WSS 的 websocket 服务器。当服务器关闭连接时,我得到了 IOException 异常并且我的 errorHandler 开始重新传递,但似乎重新传递失败(它只重新启动一次,尽管我指定 10 为最大重新传递),解决这个问题的唯一方法是重新启动我的骆驼手动路由以再次连接到 websocket 服务器。

    errorHandler(deadLetterChannel("seda:dead")
        .maximumRedeliveries(10).useExponentialBackOff()
        .log("Route exception"));

    fromF("ahc-wss://some-url&bridgeErrorHandler=true&sendMessageOnError=true")
        .filter(exchange -> exchange.getIn().getBody() != null)
        .process(exchange -> {
            String msg = (String) exchange.getIn().getBody();
            log.info("Message size: " + msg.length());
        })
        .log("test done");
4

0 回答 0