bunnicula.protocol — nomnom/bunnicula 2.2.3-SNAPSHOT-1

Monitoring clj protocol

on-error clj

(on-error this args)

Called when consumer fails because of known behavior and we error out ourselves.

on-exception clj

(on-exception this args)

Called when consumer fails because of an uncontrollable error (e.g. network, bug), basically an exception

on-retry clj

(on-retry this args)

Called when consumer fails because of known behviour and we want to retry.

on-success clj

(on-success this args)

Called when message is succesfully processed

on-timeout clj

(on-timeout this args)

Called when messsage processing timeouts.

with-tracking clj

(with-tracking this args)

Should evaluate body. Can add time tracking etc.

Publisher clj protocol

publish clj

(publish this routing-key body)

(publish this routing-key body options)

(publish this exchange-name routing-key body options)

Publish body to RabbitMQ using exchange & routing-key