(on-error this args)
Called when consumer fails because of known behavior and we error out ourselves.
Called when consumer fails because of known behavior and we error out ourselves.
(on-exception this args)
Called when consumer fails because of an uncontrollable error (e.g. network, bug), basically an exception
Called when consumer fails because of an uncontrollable error (e.g. network, bug), basically an exception
(on-retry this args)
Called when consumer fails because of known behviour and we want to retry.
Called when consumer fails because of known behviour and we want to retry.
(on-success this args)
Called when message is succesfully processed
Called when message is succesfully processed
(on-timeout this args)
Called when messsage processing timeouts.
Called when messsage processing timeouts.
(with-tracking this args)
Should evaluate body. Can add time tracking etc.
Should evaluate body. Can add time tracking etc.
(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
Publish body to RabbitMQ using exchange & routing-key
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close