Я проверяю RabbitMQ на мой проект symfony. My POC делает что-то очень простое, когда я обновляю перевод, я хочу перестроить кеш. Построение кеша производится потребителем rabbitMQ.RabbitMQ symfony doctrine всегда возвращает тот же результат
Все работает, кроме одного: я всегда получаю тот же результат доктрины.
Например, если я обновляю «привет мир», переводя «Привет всем», он правильно обновляется в БД, я отправляю сообщение потребителю для обновления кеша, потребитель получает новый перевод в БД и ... этот это старый перевод, который вернулся.
Я бегу RabbitMQ с этой командой: php app/console rabbitmq:consumer store_in_cache
Если перезапустить процесс его работы в первом сообщении, но не для последующих сообщений.
У вас есть идея?
Трудно сказать что-то, не взяв кусок кода, но вы можете посмотреть http://www.inanzzz.com/index.php/posts/rabbitmq для примеров symfony + RabbitMQ. – BentCoder