@@ -76,7 +76,7 @@ discard block |
||
76 | 76 | ) |
77 | 77 | ); |
78 | 78 | |
79 | - list($queueName, ,) = $channel->queue_declare( |
|
79 | + list($queueName,,) = $channel->queue_declare( |
|
80 | 80 | "", |
81 | 81 | false, |
82 | 82 | false, |
@@ -92,7 +92,7 @@ discard block |
||
92 | 92 | ) |
93 | 93 | ); |
94 | 94 | |
95 | - $callback = function ($msg) use ($output, $formatter, $serializer) { |
|
95 | + $callback = function($msg) use ($output, $formatter, $serializer) { |
|
96 | 96 | $reader = new EventMessageReader($serializer); |
97 | 97 | $message = $reader->readEventMessage($msg->body); |
98 | 98 |
@@ -322,7 +322,7 @@ |
||
322 | 322 | ->cannotBeEmpty() |
323 | 323 | ->validate() |
324 | 324 | ->ifNotInArray(['orm', 'event_sourcing', 'hybrid']) |
325 | - ->thenInvalid("Invalid repository type %s, possible values are " . |
|
325 | + ->thenInvalid("Invalid repository type %s, possible values are ". |
|
326 | 326 | "[\"orm\",\"event_sourcing\",\"hybrid\"]") |
327 | 327 | ->end() |
328 | 328 | ->end() |
@@ -374,7 +374,7 @@ discard block |
||
374 | 374 | 'setDispatchInterceptors', |
375 | 375 | [ |
376 | 376 | array_map( |
377 | - function ($interceptor) { |
|
377 | + function($interceptor) { |
|
378 | 378 | return new Reference($interceptor); |
379 | 379 | }, |
380 | 380 | $bus['dispatch_interceptors'] |
@@ -413,7 +413,7 @@ discard block |
||
413 | 413 | 'setHandlerInterceptors', |
414 | 414 | [ |
415 | 415 | array_map( |
416 | - function ($interceptor) { |
|
416 | + function($interceptor) { |
|
417 | 417 | return new Reference($interceptor); |
418 | 418 | }, |
419 | 419 | $bus['handler_interceptors'] |
@@ -152,7 +152,7 @@ |
||
152 | 152 | $def = $this->testSubject->getDefinition($id); |
153 | 153 | |
154 | 154 | $this->assertEquals(Dummy1Aggregate::class, $def->getArgument(0)); |
155 | - $count++;; |
|
155 | + $count++; ; |
|
156 | 156 | } |
157 | 157 | } |
158 | 158 |