phpamqplib потребляет и забывает неупакованные сообщения - PullRequest
0 голосов
/ 01 октября 2018

Я пытаюсь понять поведение сообщения 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» находится здесь.

Вопрос: Почему все сообщения потребляются до вызовов обратного вызова (и подтверждения / нет)?

Фредерик

...