Общение между сообщениями RabbitMq

Я использую RabbitMq с AMQP и Symfony2.

У меня проблема с несколькими работниками, и когда я получаю несколько сообщений от одного и того же типа в очереди, они выбираются потребителями, и они начинают работать на одном и том же объекте и перезаписывают данные друг друга (один и тот же потребитель выполняется на 2 или больше работников на тот момент).

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

Есть ли способ, которым сообщения могут обмениваться данными друг с другом или как-то устанавливать флаги в RabbitMq, может быть, чтобы другое сообщение могло проверить это, чтобы я избегал параллельного выполнения потребителем на том же объекте?

Спасибо