来自带有AMQPBridge的Vertx的Java运行时警告

Question

我在AQMP 1.0的Vertx IO中使用以下Java代码段：

    this.vertx = Vertx.vertx();

    AmqpBridge bridge = AmqpBridge.create(this.vertx);

    // Start the bridge, then use the event loop thread to process things
    // thereafter.
    bridge.start(hostname, port,
            username, password, res -> {

                // Set up a consumer using the bridge, register a handler for it.
                MessageConsumer<String> consumer = bridge
                        .createConsumer(this.processorConfiguration.getQueueName());

                // Add the message handler.
                consumer.handler(vertxMsg -> {
                    String payload = vertxMsg.body();

                    logger.debug("Rx: " + payload);
                });

                consumer.exceptionHandler(error -> {

                    logger.error("Error - " + error.getMessage());
                });
            });
}

当我运行此代码时，我得到：

2019-08-27 10:28:27，071 WARN(Slf4JLogger.java:151)-激发了一个exceptionCaught()事件，它到达了管道的尾部。这通常意味着管道中的最后一个处理程序没有处理异常。io . netty . channel . channelpipeline exception:io . vertx . core . net . impl . vertxhandler . handler added()抛出了异常；已移除。在io . netty . channel . defaultchannelpipeline . callhandler added 0(defaultchannelpipeline . Java:616)在io.vertx . core . net . impl . net client impl . Java:233)在io . vertx...还有21个

这只是一个警告，但这是我需要解决的问题吗？我似乎无法找出未处理的异常是什么。我目前无法让我的应用程序接收任何消息，所以我正试图弄清楚这是否相关，或者（更有可能）我正在做其他愚蠢的错误。

我想当我使用AmqpClient而不是使用:

https://vertx.io/docs/vertx-amqp-client/java/

谢啦

Answer 1

发布后不久，我灵机一动，查看了我正在使用的POM文件。其中一个依赖项使用的是旧版本的Netty，这导致了此警告。我升级了依赖项，它使用了新版本的Netty，警告消失了，我现在可以接收消息了。干杯！