File tree Expand file tree Collapse file tree 2 files changed +4
-2
lines changed Expand file tree Collapse file tree 2 files changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -46,8 +46,8 @@ private static function createContainer(
46
46
Hydrator::class => function (LoopInterface $ loop , CommandBusInterface $ commandBus ) use ($ options ) {
47
47
return self ::createHydrator ($ loop , $ commandBus , $ options );
48
48
},
49
- CommandBusInterface::class => function (ContainerInterface $ container ) {
50
- return CommandBusFactory::create ($ container );
49
+ CommandBusInterface::class => function (ContainerInterface $ container ) use ( $ options ) {
50
+ return CommandBusFactory::create ($ container, $ options [Options:: COMMAND_BUS_OPTIONS ] ?? [] );
51
51
},
52
52
]);
53
53
$ builder ->addDefinitions ($ options [Options::CONTAINER_DEFINITIONS ] ?? []);
Original file line number Diff line number Diff line change @@ -9,4 +9,6 @@ final class Options
9
9
const TRANSPORT = 'transport ' ;
10
10
const TRANSPORT_OPTIONS = 'transport_options ' ;
11
11
const CONTAINER_DEFINITIONS = 'container_definitions ' ;
12
+ const CONTAINER = 'container ' ;
13
+ const COMMAND_BUS_OPTIONS = 'command_bus_options ' ;
12
14
}
You can’t perform that action at this time.
0 commit comments