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

convert-and-ack-message clj

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

De-serializes the message payload (payload) using nippy/thaw and converts it to MessagePayload. Acks the message if ack? is true.

get-dead-set-messages clj

(get-dead-set-messages topic-entity count)

(get-dead-set-messages topic-entity channel count)

This method can be used to read and optionally ack messages in dead-letter queue, based on the value of ack?.

For example, this method can be used to delete messages from dead-letter queue if ack? is set to true.

process-dead-set-messages clj

(process-dead-set-messages topic-entity count processing-fn)

(process-dead-set-messages topic-entity channel count processing-fn)

This method reads and processes count number of messages from RabbitMQ dead-letter queue for topic topic-entity and channel specified by channel. Executes processing-fn for every message read from the queue.

process-message-from-queue clj

(process-message-from-queue ch meta payload topic-entity processing-fn)

read-message-from-queue clj

(read-message-from-queue ch queue-name topic-entity ack?)

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