@@ -36,7 +36,7 @@ discard block |
||
36 | 36 | $pipelineModifications->registerStep( |
37 | 37 | 'OutgoingLogicalMessageMutation', |
38 | 38 | OutgoingLogicalMessageMutationPipelineStep::class, |
39 | - function () use ($builder) { |
|
39 | + function() use ($builder) { |
|
40 | 40 | return new OutgoingLogicalMessageMutationPipelineStep($builder->build(MessageMutatorRegistry::class)); |
41 | 41 | } |
42 | 42 | ); |
@@ -44,7 +44,7 @@ discard block |
||
44 | 44 | $pipelineModifications->registerStep( |
45 | 45 | 'OutgoingPhysicalMessageMutation', |
46 | 46 | OutgoingPhysicalMessageMutationPipelineStep::class, |
47 | - function () use ($builder) { |
|
47 | + function() use ($builder) { |
|
48 | 48 | return new OutgoingPhysicalMessageMutationPipelineStep($builder->build(MessageMutatorRegistry::class)); |
49 | 49 | } |
50 | 50 | ); |
@@ -218,7 +218,7 @@ |
||
218 | 218 | |
219 | 219 | $factory = $this->values[$id]; |
220 | 220 | |
221 | - $extended = function ($c) use ($callable, $factory) { |
|
221 | + $extended = function($c) use ($callable, $factory) { |
|
222 | 222 | return $callable($factory($c), $c); |
223 | 223 | }; |
224 | 224 |
@@ -28,7 +28,7 @@ |
||
28 | 28 | */ |
29 | 29 | public function formalize(Settings $settings) |
30 | 30 | { |
31 | - return function () { |
|
31 | + return function() { |
|
32 | 32 | return new TimestampFirstCombGenerator(); |
33 | 33 | }; |
34 | 34 | } |
@@ -501,21 +501,21 @@ discard block |
||
501 | 501 | $c[OutgoingOptionsFactory::class] |
502 | 502 | ); |
503 | 503 | |
504 | - $c[IncomingContextFactory::class] = function ($c) { |
|
504 | + $c[IncomingContextFactory::class] = function($c) { |
|
505 | 505 | return new IncomingContextFactory($c[BusOperations::class], $c[OutgoingOptionsFactory::class]); |
506 | 506 | }; |
507 | - $c[OutgoingContextFactory::class] = function () { |
|
507 | + $c[OutgoingContextFactory::class] = function() { |
|
508 | 508 | return new OutgoingContextFactory(); |
509 | 509 | }; |
510 | 510 | |
511 | - $c[ClockInterface::class] = function () { |
|
511 | + $c[ClockInterface::class] = function() { |
|
512 | 512 | return new SystemClock(); |
513 | 513 | }; |
514 | - $c[DateTimeConverter::class] = function () { |
|
514 | + $c[DateTimeConverter::class] = function() { |
|
515 | 515 | return new DateTimeConverter(); |
516 | 516 | }; |
517 | 517 | |
518 | - $c[PushPipe::class] = function ($c) { |
|
518 | + $c[PushPipe::class] = function($c) { |
|
519 | 519 | /** @var PipelineFactory $pipelineFactory */ |
520 | 520 | $pipelineFactory = $c[PipelineFactory::class]; |
521 | 521 | return new PushPipe( |
@@ -526,7 +526,7 @@ discard block |
||
526 | 526 | ) |
527 | 527 | ); |
528 | 528 | }; |
529 | - $c[PushSettings::class] = function () { |
|
529 | + $c[PushSettings::class] = function() { |
|
530 | 530 | $errorQueue = $this->settings->tryGet(KnownSettingsEnum::ERROR_QUEUE); |
531 | 531 | if (!$errorQueue) { |
532 | 532 | throw new UnexpectedValueException( |
@@ -539,7 +539,7 @@ discard block |
||
539 | 539 | $this->settings->tryGet(KnownSettingsEnum::PURGE_ON_STARTUP) ?: false |
540 | 540 | ); |
541 | 541 | }; |
542 | - $c[TransportReceiver::class] = function ($c) { |
|
542 | + $c[TransportReceiver::class] = function($c) { |
|
543 | 543 | return new TransportReceiver( |
544 | 544 | $c[MessagePusherInterface::class], |
545 | 545 | $c[PushSettings::class], |