Sending messages to channels handled by reactive messaging

[rmgn91]

Hi all!

I'm trying to understand how can I detect that my broker is down when I'm trying to send a message without blocking? I was using this code as it's described from the documentation:

public void sendAsMessageWithAck(double d) {
    emitterForPrices.send(Message.of(d, () -> {
            // Called when the message is acknowledged.
            return CompletableFuture.completedFuture(null);
        },
        reason -> {
            // Called when the message is acknowledged negatively.
            return CompletableFuture.completedFuture(null);
        }));

I was expecting that the message would be Nacked (as per a default timeout) and I could then take some action. I know that I can achieve this the following way as described below, but this would be blocking.

public void sendAndAwaitAcknowledgement(double d) {
    CompletionStage<Void> acked = emitterForPrices.send(d);
    // sending a payload returns a CompletionStage completed
    // when the message is acknowledged
    acked.toCompletableFuture().orTimeout(1000,TimeUnit.MILLISECONDS).join();
}

Thanks!