(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.
(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.
(get-dead-set-queue-name topic-entity ziggurat-config)(get-dead-set-queue-name topic-entity ziggurat-config channel)(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.
(start-retry-subscriber* mapper-fn topic-entity channels ziggurat-config)(start-subscribers stream-routes ziggurat-config)Starts the subscriber to the instant queue of the rabbitmq
Starts the subscriber to the instant queue of the rabbitmq
cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |