Я пытаюсь понять поведение сообщения unacknoledge с phpamqplib.
Я поставил свою проблему здесь: https://gist.github.com/f2r/0632b651a3b27a2c189652b753f45e49
Первый результат выполнения:
Queue: queue.test, message count: 4, consumer count: 0
Queue: queue.test, message count: 0, consumer count: 1
Message 1 => unknow
Message 2 => ack
Message 3 => ack
Message 4 => end
Как видите, перед потреблением есть 4 сообщения, а после потребления (до ожидания) сообщения не осталось.Кроме того, мое «неизвестное» сообщение не доставлено.
Теперь, если я перезапущу свой скрипт, вот результат:
Queue: queue.test, message count: 5, consumer count: 0
Queue: queue.test, message count: 0, consumer count: 1
Message 1 => unknow
*** redelivered
Message 1 => unknow
Message 2 => ack
Message 3 => ack
Message 4 => end
Теперь у меня 5 сообщений, и мойпредыдущее сообщение «unnonoledged» находится здесь.
Вопрос: Почему все сообщения потребляются до вызовов обратного вызова (и подтверждения / нет)?
Фредерик