无法使用自定义名称成功将 RabbitMQ 消息发布到队列
P粉302484366
P粉302484366 2024-03-26 19:54:35
[PHP讨论组]

我想将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"

热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责申明 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送
PHP中文网APP
随时随地碎片化学习
PHP中文网抖音号
发现有趣的

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号