Tidak berjaya menerbitkan mesej RabbitMQ untuk beratur menggunakan nama tersuai
P粉302484366
P粉302484366 2024-03-26 19:54:35
0
1
436

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.

P粉302484366
P粉302484366

membalas semua(1)
P粉448346289

Saya jumpa jawapannya. Anda hanya menambah nama baris gilir pada RABBITMQ_URL.

URL = amqp://guest:guest@localhost:5672/"vhost"/"queuename"

Muat turun terkini
Lagi>
kesan web
Kod sumber laman web
Bahan laman web
Templat hujung hadapan