Я следую этому документу https://www.squaremobius.net/amqp.node/channel_api.html#channel_cancel
Следующий код прекращает отправку сообщения потребителю:
channel.cancel(consumer.consumerTag);
Но я хочу возобновить отправку сообщения потребителю? Есть ли способ сделать это?
Мне нужна такая функция, как: queue.subscribe и queue.unsubscribe
Эти два метода предоставляются библиотекой amqp
.
Какая эквивалентная функция используется amqplib
?
обновление
Я пытался channel.recover()
, но rabbitmq больше не отправляет неподтвержденное сообщение потребителю.