ziggurat.messaging.consumer — tech.gojek/ziggurat 2.8.0

close clj

(close channel)

convert-and-ack-message clj

(convert-and-ack-message ch {:keys [delivery-tag] :as meta} payload ack?)

Take the ch metadata payload and ack? as parameter. Decodes the payload the ack it if ack is enabled and returns the message

get-dead-set-messages-for-channel clj

(get-dead-set-messages-for-channel ack? topic channel count)

get-dead-set-messages-for-topic clj

(get-dead-set-messages-for-topic ack? topic count)

start-channels-subscriber clj

(start-channels-subscriber channels topic-entity)

start-retry-subscriber* clj

(start-retry-subscriber* mapper-fn topic-entity channels)

start-subscribers clj

(start-subscribers stream-routes)

Starts the subscriber to the instant queue of the rabbitmq