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

convert-to-message-payload clj

(convert-to-message-payload message topic-entity)

This function is used for migration from Ziggurat Version 2.x to 3.x. It checks if the message is a message payload or a message(pushed by Ziggurat version < 3.0.0) and converts messages to message-payload to pass onto the mapper-fn.

If the :retry-count key is absent in the message, then it puts 0 as the value for :retry-count in MessagePayload. It also converts the topic-entity into a keyword while constructing MessagePayload.

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.

get-dead-set-queue-name clj

(get-dead-set-queue-name topic-entity ziggurat-config)

(get-dead-set-queue-name topic-entity ziggurat-config channel)

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-messages-from-queue clj

(process-messages-from-queue queue-name count processing-fn)

read-messages-from-queue clj

(read-messages-from-queue queue-name topic-entity ack? count)

start-channels-subscriber clj

(start-channels-subscriber channels topic-entity ziggurat-config)

start-retry-subscriber* clj

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

start-subscribers clj

(start-subscribers stream-routes ziggurat-config)

Starts the subscriber to the instant queue of the rabbitmq