HareMq.RetryPublisher
(hare_mq v1.4.0)
Copy Markdown
Module providing functions for republishing messages with retry handling.
This module includes functions for determining retry count, republishing to delay queues, and handling retries.
Summary
Functions
Republish a message to either a delay or dead letter queue based on the retry count.
Republish a specified number of dead messages from the dead letter queue.
Determine the retry count from message headers.
Functions
Republish a message to either a delay or dead letter queue based on the retry count.
Parameters
payload: The message payload.configuration: A%Configuration{}struct containing queue configuration.metadata: Message metadata.
Examples
HareMq.RetryPublisher.republish(payload, configuration, metadata)Republish a specified number of dead messages from the dead letter queue.
Parameters
configuration: A%Configuration{}struct containing queue configuration.count: The number of dead messages to republish.
Examples
HareMq.RetryPublisher.republish_dead_messages(configuration, 5)Determine the retry count from message headers.
Parameters
headers: Message headers.
Examples
retry_count = HareMq.RetryPublisher.retry_count(headers)