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