Skip to content

Commit 48e8ffe

Browse files
committed
[Messenger] Add handled & sent stamps
1 parent a8c8fc1 commit 48e8ffe

File tree

2 files changed

+8
-4
lines changed

2 files changed

+8
-4
lines changed

DependencyInjection/FrameworkExtension.php

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1578,9 +1578,10 @@ private function registerMessengerConfiguration(array $config, ContainerBuilder
15781578
if ('*' !== $message && !class_exists($message) && !interface_exists($message, false)) {
15791579
throw new LogicException(sprintf('Invalid Messenger routing configuration: class or interface "%s" not found.', $message));
15801580
}
1581-
$senders = array_map(function ($sender) use ($senderAliases) {
1582-
return new Reference($senderAliases[$sender] ?? $sender);
1583-
}, $messageConfiguration['senders']);
1581+
$senders = array();
1582+
foreach ($messageConfiguration['senders'] as $sender) {
1583+
$senders[$sender] = new Reference($senderAliases[$sender] ?? $sender);
1584+
}
15841585

15851586
$sendersId = 'messenger.senders.'.$message;
15861587
$container->register($sendersId, RewindableGenerator::class)

Tests/DependencyInjection/FrameworkExtensionTest.php

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -569,7 +569,10 @@ public function testMessengerRouting()
569569
);
570570

571571
$this->assertSame($messageToSendAndHandleMapping, $senderLocatorDefinition->getArgument(1));
572-
$this->assertEquals(array(new Reference('messenger.transport.amqp'), new Reference('audit')), $container->getDefinition('messenger.senders.'.DummyMessage::class)->getArgument(0)[0]->getValues());
572+
$this->assertEquals(array(
573+
'amqp' => new Reference('messenger.transport.amqp'),
574+
'audit' => new Reference('audit'),
575+
), $container->getDefinition('messenger.senders.'.DummyMessage::class)->getArgument(0)[0]->getValues());
573576
}
574577

575578
/**

0 commit comments

Comments
 (0)