Merge pull request #15 from prooph/fix_container_plugin

MessageBusFactory cannot access private service
prooph · Apr 1, 2017 · b6436b2 · b6436b2
2 parents 0f7d17a + d937e52
commit b6436b2
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/src/DependencyInjection/ProophServiceBusExtension.php b/src/DependencyInjection/ProophServiceBusExtension.php
@@ -146,6 +146,7 @@ private function loadBus(string $type, string $name, array $options, ContainerBu
         $messageFactoryPluginId = 'prooph_service_bus.message_factory_plugin.'.$name;
         $messageFactoryPluginDefinition = new DefinitionDecorator('prooph_service_bus.message_factory_plugin');
         $messageFactoryPluginDefinition->setArguments([new Reference($messageFactoryId)]);
+        $messageFactoryPluginDefinition->setPublic(true);
 
         $container->setDefinition(
                 $messageFactoryPluginId,
@@ -159,6 +160,7 @@ private function loadBus(string $type, string $name, array $options, ContainerBu
             $routerId = 'prooph_service_bus.' . $name . '.router';
             $routerDefinition = new DefinitionDecorator($options['router']['type']);
             $routerDefinition->setArguments([$options['router']['routes'] ?? []]);
+            $routerDefinition->setPublic(true);
             $container->setDefinition($routerId, $routerDefinition);
         }
 

diff --git a/src/Resources/config/service_bus.xml b/src/Resources/config/service_bus.xml
@@ -18,7 +18,7 @@
         <service id="prooph_service_bus.on_event_invoke_strategy" class="Prooph\ServiceBus\Plugin\InvokeStrategy\OnEventStrategy" />
         <service id="prooph_service_bus.message_factory_plugin" class="%prooph_service_bus.message_factory_plugin.class%" public="false" abstract="true" />
         <service id="prooph_service_bus.message_factory" class="%prooph_service_bus.message_factory.class%" />
-        <service id="prooph_service_bus.container_plugin" class="%prooph_service_bus.container_plugin.class%" public="false">
+        <service id="prooph_service_bus.container_plugin" class="%prooph_service_bus.container_plugin.class%">
             <argument type="service" id="prooph_service_bus.container_wrapper" />
         </service>
         <service id="prooph_service_bus.container_wrapper" class="%prooph_service_bus.container_wrapper.class%" public="false">