无法将RabbitMQ消息发布到具有自己名称的队列

xytpbqjk  于 2022-11-08  发布在  RabbitMQ
关注(0)|答案(1)|浏览(251)

我想将rabbitMQ消息发布到具有以下名称的队列:“vincent.test.rabbitMq”。我正试图用Symfony信使来做这件事。这是我的信息:

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

}

这是我的信使

framework:
    messenger:

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

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

但当我发布这样的消息时:$this->bus->dispatch(new TestMessage("testmessage123"));它将创建一个名为messages的队列。如果我用另一个名称发布另一个消息,它也将进入这个队列。我想要的是为每个消息创建一个单独的队列。

svmlkihl

svmlkihl1#

我找到了答案。您可以将queue-name添加到RABBITMQ_URL中。
URL = amqp://访客:访客@本地主机:5672/“虚拟主机”/“队列名称”

相关问题