(delay-queue-name topic-entity queue-name)
(make-queues stream-routes)
(publish-to-channel-dead-queue topic-entity channel message)
(publish-to-channel-delay-queue topic-entity channel message)
(publish-to-channel-instant-queue topic-entity channel message)
(publish-to-dead-queue topic-entity message)
(publish-to-delay-queue topic-entity message)
(publish-to-instant-queue topic-entity message)
(retry {:keys [retry-count] :as message} topic-entity)
(retry-for-channel {:keys [retry-count] :as message} topic-entity channel)
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close