Ich teste RabbitMQ auf meinem symfony Projekt. Mein POC macht etwas wirklich einfaches, wenn ich eine Übersetzung aktualisiere, möchte ich den Cache neu aufbauen. Das Erstellen des Caches wird vom RabbitMQ-Consumer vorgenommen.RabbitMQ Symfony Doktrin immer das gleiche Ergebnis
Alles funktioniert außer einer Sache: Ich bekomme immer die gleiche Lehre Ergebnis.
Zum Beispiel, wenn ich "Hallo Welt" Übersetzung von "Hallo alle" update es ist korrekt in der DB aktualisiert, ich sende eine Nachricht an den Verbraucher für die Aktualisierung der Cache, der Verbraucher die neue Übersetzung in DB und ... dies ist die alte Übersetzung, die zurückgegeben wurde.
Ich betreiben RabbitMQ mit diesem Befehl: php app/console rabbitmq:consumer store_in_cache
Wenn ich den Prozess neu starten, es für die erste Nachricht arbeiten, aber nicht für die nächsten Nachrichten.
Haben Sie eine Idee?
Es ist schwer, etwas zu sagen, ohne ein Stück Code zu verwenden, aber Sie können http://www.inanzzz.com/index.php/posts/rabbitmq für Beispiele von symfony + RabbitMQ suchen. – BentCoder