reactor/reactor-rabbitmq

AcknowledgableDelivery.ack() blocks

patrickhuy opened this issue · 1 comments

patrickhuy commented

When calling AcknowledgableDelivery.ack() with BlockHound active we can see that it directly calls into Channel.basicAck() which ends up calling SocketOutputStream.write which is a blocking operation.

Expected Behavior

Possibility to "reactivly" acknowledge a delivery without blocking.

Actual Behavior

No reactive way available - is there a recommended approach how to acknowledge messages without blocking in a reactive pipeline?

acogoluegnes commented

You can enable NIO in the Java client.

  • 👍1