ziggurat.messaging.producer — gojek.tech/ziggurat 2.7.2

delay-queue-name clj

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

make-queues clj

(make-queues stream-routes)

publish-to-channel-dead-queue clj

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

publish-to-channel-delay-queue clj

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

publish-to-channel-instant-queue clj

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

publish-to-dead-queue clj

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

publish-to-delay-queue clj

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

publish-to-instant-queue clj

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

retry clj

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

retry-for-channel clj

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