無法使用自訂名稱成功將 RabbitMQ 訊息發佈到佇列
P粉302484366
P粉302484366 2024-03-26 19:54:35
0
1
432

我想將rabbitMQ訊息發佈到名為「vincent.test.rabbitMq」的佇列。我正在嘗試使用 Symfony-messenger 來做到這一點。 這是我的消息:

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;
    }


}

這是我的Messenger.yaml:

framework:
    messenger:

        transports:
            vincent.test.rabbitMq: '%env(RABBITMQ_URL)%'

        routing:
            'App\TestRabbitMQ\TestMessage': vincent.test.rabbitMq

但是當我發布這樣的消息時: $this->bus->dispatch(new TestMessage("testmessage123")); 它將建立一個名為 messages 的佇列。如果我用另一個名稱發�

P粉302484366
P粉302484366

全部回覆(1)
P粉448346289

我找到了答案。您只需將佇列名稱新增至 RABBITMQ_URL 即可。

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

熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板