@@ 67-84 (lines=18) @@ | ||
64 | CommandHandler::class |
|
65 | ); |
|
66 | ||
67 | foreach ($inspector->getHandlerDefinitions() as $handlerDefinition) { |
|
68 | $handlerId = $this->getHandlerIdentifier("governor.command_handler"); |
|
69 | ||
70 | $container->register($handlerId, AnnotatedCommandHandler::class) |
|
71 | ->addArgument($class) |
|
72 | ->addArgument($handlerDefinition->getMethod()->name) |
|
73 | ->addArgument(new Reference('governor.parameter_resolver_factory')) |
|
74 | ->addArgument(new Reference($id)) |
|
75 | ->setPublic(true) |
|
76 | ->setLazy(true); |
|
77 | ||
78 | $bus->addMethodCall('subscribe', |
|
79 | [ |
|
80 | $handlerDefinition->getPayloadType(), |
|
81 | new Reference($handlerId) |
|
82 | ] |
|
83 | ); |
|
84 | } |
|
85 | } |
|
86 | } |
|
87 |
@@ 82-97 (lines=16) @@ | ||
79 | EventHandler::class |
|
80 | ); |
|
81 | ||
82 | foreach ($inspector->getHandlerDefinitions() as $handlerDefinition) { |
|
83 | $handlerId = $this->getHandlerIdentifier('governor.event_handler'); |
|
84 | ||
85 | $container |
|
86 | ->register($handlerId, AnnotatedEventListener::class) |
|
87 | ->addArgument($handlerDefinition->getPayloadType()) |
|
88 | ->addArgument($handlerDefinition->getMethod()->name) |
|
89 | ->addArgument(new Reference($id)) |
|
90 | ->setPublic(true) |
|
91 | ->setLazy(true); |
|
92 | ||
93 | $registry->addMethodCall( |
|
94 | 'subscribe', |
|
95 | [new Reference($handlerId)] |
|
96 | ); |
|
97 | } |
|
98 | } |
|
99 | } |
|
100 |