@@ -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 | |