langohr.confirm — com.novemberain/langohr 5.1.0

Functions that work with publisher confirms.

Relevant guides:

• http://clojurerabbitmq.info/articles/exchanges.html

add-listener clj

(add-listener channel cl)

Adds confirmations listener to given channel

listener clj

(listener ack-handler nack-handler)

Instantiates and returns a new confirmations listener that handles basic.ack and basic.nack method deliveries

select clj

(select channel)

(select channel ack-handler nack-handler)

Activates publishing confirmations on given channel.

wait-for-confirms clj

(wait-for-confirms channel)

(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. Note, when called on a non-Confirm channel, waitForConfirms throws an IllegalStateException.

Returns true if all messages were acked successfully, false otherwise.

wait-for-confirms-or-die clj

(wait-for-confirms-or-die channel)

(wait-for-confirms-or-die channel timeout)

Wait until all messages published since the last call have been either ack'd or nack'd by the broker. If any of the messages were nack'd, waitForConfirmsOrDie will throw an IOException. When called on a non-Confirm channel, it will throw an IllegalStateException.