[Messenger] Fix handles tag attribute
This commit is contained in:
parent
e973f6f380
commit
92f7e37a27
@ -69,7 +69,7 @@ class MessengerPass implements CompilerPassInterface
|
|||||||
|
|
||||||
foreach ($container->findTaggedServiceIds($this->handlerTag, true) as $serviceId => $tags) {
|
foreach ($container->findTaggedServiceIds($this->handlerTag, true) as $serviceId => $tags) {
|
||||||
foreach ($tags as $tag) {
|
foreach ($tags as $tag) {
|
||||||
$handles = $tag['handles'] ?? $this->guessHandledClasses($r = $container->getReflectionClass($container->getDefinition($serviceId)->getClass()), $serviceId);
|
$handles = isset($tag['handles']) ? array($tag['handles']) : $this->guessHandledClasses($r = $container->getReflectionClass($container->getDefinition($serviceId)->getClass()), $serviceId);
|
||||||
$priority = $tag['priority'] ?? 0;
|
$priority = $tag['priority'] ?? 0;
|
||||||
|
|
||||||
foreach ($handles as $messageClass) {
|
foreach ($handles as $messageClass) {
|
||||||
|
@ -33,6 +33,10 @@ class MessengerPassTest extends TestCase
|
|||||||
->register(DummyHandler::class, DummyHandler::class)
|
->register(DummyHandler::class, DummyHandler::class)
|
||||||
->addTag('messenger.message_handler')
|
->addTag('messenger.message_handler')
|
||||||
;
|
;
|
||||||
|
$container
|
||||||
|
->register(MissingArgumentTypeHandler::class, MissingArgumentTypeHandler::class)
|
||||||
|
->addTag('messenger.message_handler', array('handles' => SecondMessage::class))
|
||||||
|
;
|
||||||
$container
|
$container
|
||||||
->register(DummyReceiver::class, DummyReceiver::class)
|
->register(DummyReceiver::class, DummyReceiver::class)
|
||||||
->addTag('messenger.receiver')
|
->addTag('messenger.receiver')
|
||||||
@ -43,7 +47,10 @@ class MessengerPassTest extends TestCase
|
|||||||
$handlerLocatorDefinition = $container->getDefinition($container->getDefinition('messenger.handler_resolver')->getArgument(0));
|
$handlerLocatorDefinition = $container->getDefinition($container->getDefinition('messenger.handler_resolver')->getArgument(0));
|
||||||
$this->assertSame(ServiceLocator::class, $handlerLocatorDefinition->getClass());
|
$this->assertSame(ServiceLocator::class, $handlerLocatorDefinition->getClass());
|
||||||
$this->assertEquals(
|
$this->assertEquals(
|
||||||
array('handler.'.DummyMessage::class => new ServiceClosureArgument(new Reference(DummyHandler::class))),
|
array(
|
||||||
|
'handler.'.DummyMessage::class => new ServiceClosureArgument(new Reference(DummyHandler::class)),
|
||||||
|
'handler.'.SecondMessage::class => new ServiceClosureArgument(new Reference(MissingArgumentTypeHandler::class)),
|
||||||
|
),
|
||||||
$handlerLocatorDefinition->getArgument(0)
|
$handlerLocatorDefinition->getArgument(0)
|
||||||
);
|
);
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user