ziggurat.messaging.producer — tech.gojek/ziggurat 4.5.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)

This function return delay exchange name for retry when using channel flow. It will return exchange name with retry count as suffix if exponential backoff enabled.

get-channel-queue-timeout-ms clj

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

Calculate queue timeout for channel delay queue. Uses the value from [[get-exponential-backoff-timeout-ms]] if exponential backoff enabled.

get-default-ha-policy clj

(get-default-ha-policy rmq-config replica-count)

get-delay-exchange-name clj

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

This function return delay exchange name for retry when using flow without channel. It will return exchange name with retry count as suffix if exponential backoff enabled.

get-queue-timeout-ms clj

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

Calculate queue timeout for delay queue. Uses the value from [[get-exponential-backoff-timeout-ms]] if exponential backoff enabled.

get-replica-count clj

(get-replica-count host-count)

make-queues clj

(make-queues routes)

MAX_EXPONENTIAL_RETRIES clj

publish clj

(publish exchange message-payload)

(publish exchange message-payload expiration)

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] :as message-payload})

retry-for-channel clj

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

set-ha-policy clj

(set-ha-policy queue-name exchange-name rmq-config)

set-ha-policy-on-host clj

(set-ha-policy-on-host host-endpoint
                       username
                       password
                       ha-policy-body
                       exchange-name
                       queue-name)