ziggurat.messaging.producer — tech.gojek/ziggurat 3.1.0-alpha.1

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 channel message-payload)

publish-to-channel-delay-queue clj

(publish-to-channel-delay-queue channel message-payload)

publish-to-channel-instant-queue clj

(publish-to-channel-instant-queue channel message-payload)

publish-to-dead-queue clj

(publish-to-dead-queue message-payload)

publish-to-delay-queue clj

(publish-to-delay-queue message-payload)

publish-to-instant-queue clj

(publish-to-instant-queue message-payload)

retry clj

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

retry-for-channel clj

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