java - EventBus.localConsumer 是否需要 MessageConsumer.completionHandler？

Answer 1

在您的侦听器注册后，完成处理程序仅被调用一次。如果您想在someAddress发生这种情况后向其发送消息，那么您的初始代码是正确的。

由于 Vert.x 异步性质，您的第二个示例将不一致。很可能当您发送消息时，您的本地消费者尚未注册，因此消息丢失。

如果您的意图是在someAddress收到每条新消息后发送一条新消息，那么这两段代码都是错误的。