ziggurat.messaging.producer

Liking cljdoc? Tell your friends :D

Clojure only.

delay-queue-name
make-queues
publish-to-channel-dead-queue
publish-to-channel-delay-queue
publish-to-channel-instant-queue
publish-to-dead-queue
publish-to-delay-queue
publish-to-instant-queue
retry
retry-for-channel

delay-queue-name^clj

(delay-queue-name topic-entity queue-name)

source

make-queues^clj

(make-queues stream-routes)

source

publish-to-channel-dead-queue^clj

(publish-to-channel-dead-queue topic-entity channel message)

source

publish-to-channel-delay-queue^clj

(publish-to-channel-delay-queue topic-entity channel message)

source

publish-to-channel-instant-queue^clj

(publish-to-channel-instant-queue topic-entity channel message)

source

publish-to-dead-queue^clj

(publish-to-dead-queue topic-entity message)

source

publish-to-delay-queue^clj

(publish-to-delay-queue topic-entity message)

source

publish-to-instant-queue^clj

(publish-to-instant-queue topic-entity message)

source

retry^clj

(retry {:keys [retry-count] :as message} topic-entity)

source

retry-for-channel^clj

(retry-for-channel {:keys [retry-count] :as message} topic-entity channel)

source

cljdoc builds & hosts documentation for Clojure/Script libraries

Keyboard shortcuts

`Ctrl`+`k`	Jump to recent docs
`←`	Move to previous article
`→`	Move to next article
`Ctrl`+`/`	Jump to the search field

Raise an issue Browse cljdoc source Chat on Slack

× close

ziggurat.messaging.producer

delay-queue-nameclj

make-queuesclj

publish-to-channel-dead-queueclj

publish-to-channel-delay-queueclj

publish-to-channel-instant-queueclj

publish-to-dead-queueclj

publish-to-delay-queueclj

publish-to-instant-queueclj

retryclj

retry-for-channelclj

delay-queue-name^clj

make-queues^clj

publish-to-channel-dead-queue^clj

publish-to-channel-delay-queue^clj

publish-to-channel-instant-queue^clj

publish-to-dead-queue^clj

publish-to-delay-queue^clj

publish-to-instant-queue^clj

retry^clj

retry-for-channel^clj