java - 如果没有消息出现，Vertx如何让消费者超时

Question

如果在 x 秒超时后没有出现消息，我想抛出一个错误。我找不到任何内置的方法来做到这一点。有什么想法吗？

这是我当前的代码:

consumer = vertx.eventBus().consumer(correlationId);

consumer.handler(message -> {
    message.reply("Received");
    consumer.unregister();
});

consumer.exceptionHandler(exception -> {
    System.out.println("error");
    consumer.unregister();
});

Answer 1

您可以在创建消费者后使用延迟任务。

vertx.setTimer(15000, l -> {
       System.out.println("error");
       consumer.unregister();
    });