Merge pull request #47 from bl4ckbon3/fix-register-plugin-bug

Bug fixing register bus plugin
prooph · Nov 7, 2017 · 9bb961f · 9bb961f
2 parents ed2568a + 851fa54
commit 9bb961f
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/DependencyInjection/ProophServiceBusExtension.php b/src/DependencyInjection/ProophServiceBusExtension.php
@@ -131,9 +131,7 @@ private function loadBus(string $type, string $name, array $options, ContainerBu
 
         // Add plugin tag for plugins configured in the bus config
         foreach ($options['plugins'] as $pluginServiceId) {
-            $container
-                ->getDefinition($pluginServiceId)
-                ->addTag(sprintf('prooph_service_bus.%s.plugin', $name));
+            $serviceBusDefinition->addMethodCall('addPlugin', [new Reference($pluginServiceId), $pluginServiceId]);
         }
 
         // Logging for each configured service bus