| @@ -9,7 +9,6 @@ | ||
| 9 | 9 | namespace Governor\Bundle\GovernorBundle\DependencyInjection\Compiler; | 
| 10 | 10 | |
| 11 | 11 | use Governor\Framework\Annotations\CommandHandler; | 
| 12 | - | |
| 13 | 12 | use Symfony\Component\DependencyInjection\Reference; | 
| 14 | 13 | use Symfony\Component\DependencyInjection\ContainerBuilder; | 
| 15 | 14 | use Governor\Framework\CommandHandling\Handlers\AnnotatedAggregateCommandHandler; | 
| @@ -30,7 +30,6 @@ | ||
| 30 | 30 | use Governor\Framework\EventHandling\EventListenerInterface; | 
| 31 | 31 | use Governor\Framework\CommandHandling\SimpleCommandBus; | 
| 32 | 32 | use Governor\Framework\EventHandling\SimpleEventBus; | 
| 33 | -use Governor\Framework\CommandHandling\InMemoryCommandHandlerRegistry; | |
| 34 | 33 | use Governor\Framework\EventHandling\InMemoryEventListenerRegistry; | 
| 35 | 34 | use Symfony\Component\Stopwatch\Stopwatch; | 
| 36 | 35 | use Governor\Framework\EventHandling\Amqp\AmqpTerminal; | 
| @@ -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 | |
| @@ -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 | |
| @@ -49,7 +49,7 @@ discard block | ||
| 49 | 49 | ->validate() | 
| 50 | 50 | ->ifNotInArray(['annotation', 'metadata']) | 
| 51 | 51 |                          ->thenInvalid('Invalid command target resolver "%s", possible values are '. | 
| 52 | - "[\"annotation\",\"metadata\"]") | |
| 52 | + "[\"annotation\",\"metadata\"]") | |
| 53 | 53 | ->end() | 
| 54 | 54 | ->end() | 
| 55 | 55 |                  ->scalarNode('order_resolver') | 
| @@ -60,7 +60,7 @@ discard block | ||
| 60 | 60 | ->validate() | 
| 61 | 61 | ->ifNotInArray(['null', 'optimistic', 'pesimistic']) | 
| 62 | 62 |                          ->thenInvalid('Invalid lock manager "%s", possible values are '. | 
| 63 | - "[\"null\",\"optimistic\",\"pesimistic\"]") | |
| 63 | + "[\"null\",\"optimistic\",\"pesimistic\"]") | |
| 64 | 64 | ->end() | 
| 65 | 65 | ->end() | 
| 66 | 66 |                  ->arrayNode('annotation_reader') | 
| @@ -88,7 +88,7 @@ discard block | ||
| 88 | 88 | ->validate() | 
| 89 | 89 | ->ifNotInArray(['orm', 'mongo', 'filesystem']) | 
| 90 | 90 |                                  ->thenInvalid('Invalid event store "%s", possible values are '. | 
| 91 | - "[\"orm\",\"mongo\", \"filesystem\"]") | |
| 91 | + "[\"orm\",\"mongo\", \"filesystem\"]") | |
| 92 | 92 | ->end() | 
| 93 | 93 | ->end() | 
| 94 | 94 |                          ->arrayNode('parameters') | 
| @@ -110,7 +110,7 @@ discard block | ||
| 110 | 110 | ->validate() | 
| 111 | 111 | ->ifNotInArray(['orm', 'mongo']) | 
| 112 | 112 |                                  ->thenInvalid('Invalid saga repository "%s", possible values are '. | 
| 113 | - "[\"orm\",\"mongo\"]") | |
| 113 | + "[\"orm\",\"mongo\"]") | |
| 114 | 114 | ->end() | 
| 115 | 115 | ->end() | 
| 116 | 116 |                          ->arrayNode('parameters') | 
| @@ -126,7 +126,7 @@ discard block | ||
| 126 | 126 | ->validate() | 
| 127 | 127 | ->ifNotInArray(['jms']) | 
| 128 | 128 |                          ->thenInvalid('Invalid serializer "%s", possible values are '. | 
| 129 | - "[\"jms\"]") | |
| 129 | + "[\"jms\"]") | |
| 130 | 130 | ->end() | 
| 131 | 131 | ->end() | 
| 132 | 132 |                  ->arrayNode('saga_manager') | 
| @@ -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'] |