AMQP.Confirm
Functions that work with publisher confirms (RabbitMQ extension to AMQP 0.9.1).
Summary↑
| select(channel) | Activates publishing confirmations on the channel |
| wait_for_confirms(channel) | Wait until all messages published since the last call have been either ack’d or nack’d by the broker |
| wait_for_confirms(channel, timeout) | Wait until all messages published since the last call have been either ack’d or nack’d by the broker, or until timeout elapses |
| wait_for_confirms_or_die(channel) | Wait until all messages published since the last call have been either ack’d or nack’d by the broker, or until timeout elapses. If any of the messages were nack’d, the calling process dies |
| wait_for_confirms_or_die(channel, timeout) |
Functions
Activates publishing confirmations on the channel.
Wait until all messages published since the last call have been either ack’d or nack’d by the broker.
Wait until all messages published since the last call have been either ack’d or nack’d by the broker, or until timeout elapses.
Wait until all messages published since the last call have been either ack’d or nack’d by the broker, or until timeout elapses. If any of the messages were nack’d, the calling process dies.