MessageConsumer.completion处理程序是EventBus.local消费者所必需的吗？

Question

以下代码可以是自定义请求/响应实现的一部分。我没有使用EventBus。请求，因为我需要更多的自由，比如对一个请求发送多个响应。

String replyAddress = generateUniqueAddress();
replyConsumer = eventBus.localConsumer(replyAddress, this::handleReply);
replyConsumer.completionHandler(result -> {
  if (result.succeeded()) {
    eventBus.send("someAddress", new SomeMessageWhichContainsMyReplyAddress(replyAddress));
  }
  else {
    ...
  }
});

问题是：我真的必须等待完成处理程序，还是可以像这样简化代码？

String replyAddress = generateUniqueAddress();
replyConsumer = eventBus.localConsumer(replyAddress, this::handleReply);
eventBus.send("someAddress", new SomeMessageWhichContainsMyReplyAddress(replyAddress));

MessageConsumer的Javadoc。completionHandler描述了此方法在“注册已在集群中传播”时通知给定的处理程序。因为没有使用EventBus的集群。localConsumer，是否可以假定注册始终立即在本地事件总线上传播？我检查了Vert的实现。x 3.9.3，至少对于这个版本，注册似乎是同步的。

Answer 1

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

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

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