Saya mahu menerbitkan mesej rabbitMQ ke baris gilir bernama "vincent.test.rabbitMq". Saya cuba menggunakan Symfony-messenger untuk melakukan ini. Ini mesej saya:
class TestMessage { private string $value; /** * @param string $value */ public function __construct(string $value) { $this->value = $value; } /** * @return string */ public function getValue(): string { return $this->value; } /** * @param string $value */ public function setValue(string $value): void { $this->value = $value; } }
Ini Rasul saya.yaml:
framework: messenger: transports: vincent.test.rabbitMq: '%env(RABBITMQ_URL)%' routing: 'App\TestRabbitMQ\TestMessage': vincent.test.rabbitMq
Tetapi apabila saya menyiarkan sesuatu seperti ini:
$this->bus->dispatch(new TestMessage("testmessage123"));
Ia akan membuat baris gilir yang dipanggil mesej. Jika saya menghantar mesej lain dengan nama lain, ia akan masuk ke baris gilir ini juga. Apa yang saya mahukan ialah mempunyai baris gilir yang berasingan untuk setiap mesej.
Saya jumpa jawapannya. Anda hanya menambah nama baris gilir pada RABBITMQ_URL.
URL = amqp://guest:guest@localhost:5672/"vhost"/"queuename"