Liking cljdoc? Tell your friends :D

ziggurat.messaging.consumer


convert-to-message-payloadclj

(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.

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.
sourceraw docstring

get-dead-set-messagesclj

(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.

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.
sourceraw docstring

get-dead-set-queue-nameclj

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

process-dead-set-messagesclj

(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.

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.
sourceraw docstring

process-messages-from-queueclj

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

read-messages-from-queueclj

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

start-channels-subscriberclj

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

start-retry-subscriber*clj

(start-retry-subscriber* handler-fn topic-entity ziggurat-config)
source

start-subscribersclj

(start-subscribers stream-routes batch-routes ziggurat-config)

Starts the subscriber to the instant queue of the rabbitmq

Starts the subscriber to the instant queue of the rabbitmq
sourceraw docstring

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close