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

convert-and-ack-message clj

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

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-entity channel count)

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

(get-dead-set-messages-for-topic ack? topic-entity 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