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

delay-queue-name clj

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

get-channel-delay-exchange-name clj

(get-channel-delay-exchange-name topic-entity channel message-payload)

get-channel-queue-timeout-ms clj

(get-channel-queue-timeout-ms topic-entity channel message-payload)

get-delay-exchange-name clj

(get-delay-exchange-name topic-entity message-payload)

get-queue-timeout-ms clj

(get-queue-timeout-ms message-payload)

make-queues clj

(make-queues stream-routes)

MAX_EXPONENTIAL_RETRIES clj

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)