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