@@ -51,7 +51,7 @@ public function process(ContainerBuilder $container)
51
51
$ busIds = [];
52
52
foreach ($ container ->findTaggedServiceIds ($ this ->busTag )as $ busId =>$ tags ) {
53
53
$ busIds [] =$ busId ;
54
- if ($ container ->hasParameter ($ busMiddlewareParameter =$ busId . '.middleware ' )) {
54
+ if ($ container ->hasParameter ($ busMiddlewareParameter =$ busId. '.middleware ' )) {
55
55
$ this ->registerBusMiddleware ($ container ,$ busId ,$ container ->getParameter ($ busMiddlewareParameter ));
56
56
57
57
$ container ->getParameterBag ()->remove ($ busMiddlewareParameter );
@@ -100,7 +100,7 @@ private function registerHandlers(ContainerBuilder $container, array $busIds)
100
100
}
101
101
102
102
$ message =null ;
103
- $ handlerBuses = (array )($ tag ['bus ' ] ??$ busIds );
103
+ $ handlerBuses = (array ) ($ tag ['bus ' ] ??$ busIds );
104
104
105
105
foreach ($ handlesas $ message =>$ options ) {
106
106
$ buses =$ handlerBuses ;
@@ -144,7 +144,7 @@ private function registerHandlers(ContainerBuilder $container, array $busIds)
144
144
if ('__invoke ' !==$ method ) {
145
145
$ wrapperDefinition = (new Definition ('callable ' ))->addArgument ([new Reference ($ serviceId ),$ method ])->setFactory ('Closure::fromCallable ' );
146
146
147
- $ definitions [$ definitionId ='.messenger.method_on_object_wrapper. ' . ContainerBuilder::hash ($ message . ': ' . $ priority . ': ' . $ serviceId . ': ' . $ method )] =$ wrapperDefinition ;
147
+ $ definitions [$ definitionId ='.messenger.method_on_object_wrapper. ' . ContainerBuilder::hash ($ message. ': ' . $ priority. ': ' . $ serviceId. ': ' . $ method )] =$ wrapperDefinition ;
148
148
}else {
149
149
$ definitionId =$ serviceId ;
150
150
}
@@ -172,7 +172,7 @@ private function registerHandlers(ContainerBuilder $container, array $busIds)
172
172
foreach ($ handlersByMessageas $ message =>$ handlers ) {
173
173
$ handlerDescriptors = [];
174
174
foreach ($ handlersas $ handler ) {
175
- $ definitions [$ definitionId ='.messenger.handler_descriptor. ' . ContainerBuilder::hash ($ bus . ': ' . $ message . ': ' . $ handler [0 ])] = (new Definition (HandlerDescriptor::class))->setArguments ([new Reference ($ handler [0 ]),$ handler [1 ]]);
175
+ $ definitions [$ definitionId ='.messenger.handler_descriptor. ' . ContainerBuilder::hash ($ bus. ': ' . $ message. ': ' . $ handler [0 ])] = (new Definition (HandlerDescriptor::class))->setArguments ([new Reference ($ handler [0 ]),$ handler [1 ]]);
176
176
$ handlerDescriptors [] =new Reference ($ definitionId );
177
177
}
178
178
@@ -182,9 +182,9 @@ private function registerHandlers(ContainerBuilder $container, array $busIds)
182
182
$ container ->addDefinitions ($ definitions );
183
183
184
184
foreach ($ busIdsas $ bus ) {
185
- $ container ->register ($ locatorId =$ bus . '.messenger.handlers_locator ' , HandlersLocator::class)
185
+ $ container ->register ($ locatorId =$ bus. '.messenger.handlers_locator ' , HandlersLocator::class)
186
186
->setArgument (0 ,$ handlersLocatorMappingByBus [$ bus ] ?? []);
187
- if ($ container ->has ($ handleMessageId =$ bus . '.middleware.handle_message ' )) {
187
+ if ($ container ->has ($ handleMessageId =$ bus. '.middleware.handle_message ' )) {
188
188
$ container ->getDefinition ($ handleMessageId )
189
189
->replaceArgument (0 ,new Reference ($ locatorId ));
190
190
}
@@ -226,7 +226,7 @@ private function guessHandledClasses(\ReflectionClass $handlerClass, string $ser
226
226
throw new RuntimeException (sprintf ('Invalid handler service "%s": type-hint of argument "$%s" in method "%s::__invoke()" must be a class , "%s" given. ' ,$ serviceId ,$ parameters [0 ]->getName (),$ handlerClass ->getName (),$ type ));
227
227
}
228
228
229
- return [(string )$ parameters [0 ]->getType ()];
229
+ return [(string )$ parameters [0 ]->getType ()];
230
230
}
231
231
232
232
private function registerReceivers (ContainerBuilder $ container ,array $ busIds )
@@ -250,7 +250,7 @@ private function registerReceivers(ContainerBuilder $container, array $busIds)
250
250
251
251
$ receiverNames = [];
252
252
foreach ($ receiverMappingas $ name =>$ reference ) {
253
- $ receiverNames [(string )$ reference ] =$ name ;
253
+ $ receiverNames [(string )$ reference ] =$ name ;
254
254
}
255
255
256
256
$ buses = [];
@@ -292,8 +292,8 @@ private function registerReceivers(ContainerBuilder $container, array $busIds)
292
292
private function registerBusToCollector (ContainerBuilder $ container ,string $ busId )
293
293
{
294
294
$ container ->setDefinition (
295
- $ tracedBusId ='debug.traced. ' . $ busId ,
296
- (new Definition (TraceableMessageBus::class, [new Reference ($ tracedBusId . '.inner ' )]))->setDecoratedService ($ busId )
295
+ $ tracedBusId ='debug.traced. ' . $ busId ,
296
+ (new Definition (TraceableMessageBus::class, [new Reference ($ tracedBusId. '.inner ' )]))->setDecoratedService ($ busId )
297
297
);
298
298
299
299
$ container ->getDefinition ('data_collector.messenger ' )->addMethodCall ('registerBus ' , [$ busId ,new Reference ($ tracedBusId )]);
@@ -305,7 +305,7 @@ private function registerBusMiddleware(ContainerBuilder $container, string $busI
305
305
foreach ($ middlewareCollectionas $ middlewareItem ) {
306
306
$ id =$ middlewareItem ['id ' ];
307
307
$ arguments =$ middlewareItem ['arguments ' ] ?? [];
308
- if (!$ container ->has ($ messengerMiddlewareId ='messenger.middleware. ' . $ id )) {
308
+ if (!$ container ->has ($ messengerMiddlewareId ='messenger.middleware. ' . $ id )) {
309
309
$ messengerMiddlewareId =$ id ;
310
310
}
311
311
@@ -316,7 +316,7 @@ private function registerBusMiddleware(ContainerBuilder $container, string $busI
316
316
if ($ container ->findDefinition ($ messengerMiddlewareId )->isAbstract ()) {
317
317
$ childDefinition =new ChildDefinition ($ messengerMiddlewareId );
318
318
$ childDefinition ->setArguments ($ arguments );
319
- $ container ->setDefinition ($ messengerMiddlewareId =$ busId . '.middleware. ' . $ id ,$ childDefinition );
319
+ $ container ->setDefinition ($ messengerMiddlewareId =$ busId. '.middleware. ' . $ id ,$ childDefinition );
320
320
}elseif ($ arguments ) {
321
321
throw new RuntimeException (sprintf ('Invalid middleware factory "%s": a middleware factory must be an abstract definition. ' ,$ id ));
322
322
}