Symfony 6.4 Messenger问题,#[AsMessageHandler(fromTransport:“sync”)]

我已经用Symfony 6.4和Messenger配置了我的项目。我在事件总线上创建了两个传输(同步和异步)。当我发送一条消息时,这条消息会在2个传输上发送,这就是我想要的。在处理程序上,我添加了fromTransport属性来定义处理程序何时运行。通常情况下,消息必须仅在传输同步时处理,但它也在异步上运行。。。

我不知道,如果我的配置出错了,或者是一个bug,我就打开了一个问题 https://github.com/symfony/symfony/issues/54543

信使.yaml

messenger:
    reset_on_message: true
    buses:
        bus.event:
            default_middleware:
                enabled: true
                allow_no_handlers: true
    failure_transport: failed

    transports:
        async:
            dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
            options:
                queue_name: async
            retry_strategy:
                max_retries: 3
                delay: 60000
                multiplier: 2
                max_delay: 0
            serializer: messenger.transport.symfony_serializer

        failed: 'doctrine://default?queue_name=failed'

        sync: 'sync://'

    routing:
        App\Message\Event\MessageEventInterface: [async, sync]
when@test:
    framework:
        messenger:
            transports:
                async: 'in-memory://'

services.yaml

    App\MessageHandler\Event\:
    resource: '../src/MessageHandler/Event'
    autoconfigure: false
    tags: [ { name: messenger.message_handler, bus: bus.event } ]

我的管理员

    <?php

declare(strict_types=1);

namespace App\MessageHandler\Event\Test;

use App\Message\Event\Agent\AgentTestedEvent;
use Psr\Log\LoggerInterface;
use Symfony\Component\Messenger\Attribute\AsMessageHandler;

#[AsMessageHandler(bus: 'bus.event', fromTransport: 'sync')]
class TestAgentTested extends TestAgentMessageHandlerAbstract
{

    public function __construct(private readonly LoggerInterface $logger)
    {
    }

    public function __invoke(AgentTestedEvent $testedEvent): void
    {

        $this->logger->error('test lance ' . $testedEvent->getAgentUuid());
    }
}