amqp v0.3.1 AMQP.Confirm View Source

Functions that work with publisher confirms (RabbitMQ extension to AMQP 0.9.1).

Link to this section Summary

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_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)

Link to this section Functions

select(channel)

select(AMQP.Channel.t) :: :ok

Activates publishing confirmations on the channel.

wait_for_confirms(channel)

wait_for_confirms(AMQP.Channel.t) :: boolean | :timeout

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_for_confirms(AMQP.Channel.t, non_neg_integer) ::
  boolean |
  :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_for_confirms_or_die(AMQP.Channel.t) :: true

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)

wait_for_confirms_or_die(AMQP.Channel.t, non_neg_integer) :: true