(convert-and-ack-message ch {:keys [delivery-tag] :as meta} payload ack?)
Take the ch metadata payload and ack? as parameter. Decodes the payload the ack it if ack is enabled and returns the message
Take the ch metadata payload and ack? as parameter. Decodes the payload the ack it if ack is enabled and returns the message
(get-dead-set-messages-for-channel ack? topic channel count)
(start-subscribers stream-routes)
Starts the subscriber to the instant queue of the rabbitmq
Starts the subscriber to the instant queue of the rabbitmq
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close