Установить пользовательские попытки доставки сообщений в amqplib(rabbitmq) в узле js
Я использую модуль js amqplib для реализации rabbitmq в моем приложении. Я изучил всю документацию, но не могу выяснить, как мы можем настроить пользовательские попытки отправки сообщений.
Также я хочу получить доступ к тем сообщениям в очереди, которые превысили максимальное количество попыток отправки, и я хочу пометить эту запись как полностью потерпевшую неудачу. Я сделал все это в библиотеке kue, но большинство людей используют amqplib для реализации очереди сообщений.
Любой может подсказать мне, как этого добиться, используя модуль amqplib.