Как не ставить в очередь с одинаковыми именами?

Question

[romaaa32]

Каким образом можно сделать так, чтобы в очередь не попадали сообщения с одинаковыми именами?
В php-amqplib еть инситрументы для такой задачи?

Может я не правильно вопрос задаю, ибо в гугле найти ответ на этот вопрос не могу)

Answer 1

[Сергей Тихонов]

В протоколе AMQP нет понятия имени или идентификатора сообщения. Вам придется добавлять uuid в тело и управлять уникальностью извне (например, ставить локи в Redis)

Comments

[romaaa32]

Спасибо, появились некоторые мысли как сделать это с помощью Redis.

Answer 2

[d-sem]

Не давать сообщениям одинаковые имена. Чего необходимо достичь?

Comments

[romaaa32]

Допустим раз в 5 минут добавляются в очередь сообщения с определенным именем (идентификатором), этих имен сотни, и потребитель в зависимости от этого имени выполняет то или иное действие. Чтобы эти действия 100% выполнялись решил сделать через очереди, но в тоже время не нужно чтобы одинаковые имена добавлялись в очередь, если оно там есть или выполняется и еще не подтверждено.

[d-sem]

romaaa32, в таком случае, вам необходима "прослойка" в виде хранилища, которая контролирует вход и выход из очереди, как правильно заметили выше. Дополнительно, это повысит надежность системы, так как очереди могут упасть.