Skip to content

Commit e873c90

Browse files
authored
Merge pull request #36 from mtarld/feature/tag-pusblishers
Add mercure.publisher tag to publisher services
2 parents a18bba0 + 01f8182 commit e873c90

File tree

3 files changed

+10
-1
lines changed

3 files changed

+10
-1
lines changed

CHANGELOG.md

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,11 @@
11
CHANGELOG
22
=========
33

4+
0.2.7
5+
-----
6+
7+
* Add `mercure.publisher` tag on publisher services
8+
49
0.2.6
510
-----
611

src/DependencyInjection/MercureExtension.php

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,10 @@ public function load(array $configs, ContainerBuilder $container)
7474

7575
$bus = $hub['bus'] ?? null;
7676
$attributes = null === $bus ? [] : ['bus' => $hub['bus']];
77-
$publisherDefinition->addTag('messenger.message_handler', $attributes);
77+
78+
$publisherDefinition
79+
->addTag('messenger.message_handler', $attributes)
80+
->addTag('mercure.publisher');
7881

7982
if ($enableProfiler) {
8083
$container->register("$hubId.traceable", TraceablePublisher::class)

tests/DependencyInjection/MercureExtensionTest.php

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,7 @@ public function testExtension()
4242
$this->assertTrue($container->hasDefinition('mercure.hub.default.jwt_provider'));
4343
$this->assertTrue($container->hasDefinition('mercure.hub.default.publisher'));
4444
$this->assertSame('https://demo.mercure.rocks/hub', $container->getDefinition('mercure.hub.default.publisher')->getArgument(0));
45+
$this->assertArrayHasKey('mercure.publisher', $container->getDefinition('mercure.hub.default.publisher')->getTags());
4546
$this->assertSame('eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.e30.HB0k08BaV8KlLZ3EafCRlTDGbkd9qdznCzJQ_l8ELTU', $container->getDefinition('mercure.hub.default.jwt_provider')->getArgument(0));
4647
$this->assertSame(['default' => 'https://demo.mercure.rocks/hub'], $container->getParameter('mercure.hubs'));
4748
$this->assertSame('https://demo.mercure.rocks/hub', $container->getParameter('mercure.default_hub'));

0 commit comments

Comments
 (0)