langohr.confirm
Functions that work with publisher confirms.
Relevant guides:
Functions that work with publisher confirms. Relevant guides: * http://clojurerabbitmq.info/articles/exchanges.html
add-listenerclj
(add-listener channel cl)Adds confirmations listener to given channel
Adds confirmations listener to given channel
listenerclj
(listener ack-handler nack-handler)Instantiates and returns a new confirmations listener that handles basic.ack and basic.nack method deliveries
Instantiates and returns a new confirmations listener that handles basic.ack and basic.nack method deliveries
selectclj
(select channel)(select channel ack-handler nack-handler)Activates publishing confirmations on given channel.
Activates publishing confirmations on given channel.
wait-for-confirmsclj
(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 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-dieclj
(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.
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.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close