ghola / core

src/MessageMutation/IncomingMessageMutationFeature.php

Spacing +2 added lines, -2 removed lines

@@ -37,7 +37,7 @@ 
         $pipelineModifications->registerStep(
             'IncomingLogicalMessageMutation',
             IncomingLogicalMessageMutationPipelineStep::class,
-            function () use ($builder) {
+            function() use ($builder) {
                 return new IncomingLogicalMessageMutationPipelineStep(
                     $builder->build(MessageMutatorRegistry::class),
                     $builder->build(IncomingLogicalMessageFactory::class)
@@ -48,7 +48,7 @@ 
         $pipelineModifications->registerStep(
             'IncomingPhysicalMessageMutation',
             IncomingPhysicalMessageMutationPipelineStep::class,
-            function () use ($builder) {
+            function() use ($builder) {
                 return new IncomingPhysicalMessageMutationPipelineStep($builder->build(MessageMutatorRegistry::class));
             }
         );

src/MessageMutation/OutgoingMessageMutationFeature.php

Spacing +2 added lines, -2 removed lines

@@ -36,7 +36,7 @@ 
         $pipelineModifications->registerStep(
             'OutgoingLogicalMessageMutation',
             OutgoingLogicalMessageMutationPipelineStep::class,
-            function () use ($builder) {
+            function() use ($builder) {
                 return new OutgoingLogicalMessageMutationPipelineStep($builder->build(MessageMutatorRegistry::class));
             }
         );
@@ -44,7 +44,7 @@ 
         $pipelineModifications->registerStep(
             'OutgoingPhysicalMessageMutation',
             OutgoingPhysicalMessageMutationPipelineStep::class,
-            function () use ($builder) {
+            function() use ($builder) {
                 return new OutgoingPhysicalMessageMutationPipelineStep($builder->build(MessageMutatorRegistry::class));
             }
         );

src/Serialization/SerializationFeature.php

Spacing +3 added lines, -3 removed lines

@@ -42,7 +42,7 @@ 
         $builder->defineSingleton(MessageSerializerInterface::class, $serializerFactory);
         $builder->defineSingleton(
             MessageDeserializerResolver::class,
-            function () use ($builder) {
+            function() use ($builder) {
                 $serializer = $builder->build(MessageSerializerInterface::class);
                 return new MessageDeserializerResolver([$serializer], get_class($serializer));
             }
@@ -52,7 +52,7 @@ 
         $pipelineModifications->registerStep(
             'DeserializeLogicalMessageConnector',
             DeserializeLogicalMessageConnector::class,
-            function () use ($builder) {
+            function() use ($builder) {
                 return new DeserializeLogicalMessageConnector(
                     $builder->build(MessageDeserializerResolver::class),
                     $builder->build(IncomingLogicalMessageFactory::class),
@@ -63,7 +63,7 @@ 
         $pipelineModifications->registerStep(
             'SerializeMessageConnector',
             SerializeMessageConnector::class,
-            function () use ($builder) {
+            function() use ($builder) {
                 return new SerializeMessageConnector(
                     $builder->build(MessageSerializerInterface::class),
                     $builder->build(OutgoingContextFactory::class)

src/UuidGeneration/Comb/CombUuidGenerationDefinition.php

Spacing +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
      */
     public function formalize(Settings $settings)
     {
-        return function () {
+        return function() {
             return new TimestampFirstCombGenerator();
         };
     }

src/EndpointConfigurator.php

Spacing +7 added lines, -7 removed lines

@@ -501,21 +501,21 @@ 
             $c[OutgoingOptionsFactory::class]
         );
 
-        $c[IncomingContextFactory::class] = function ($c) {
+        $c[IncomingContextFactory::class] = function($c) {
             return new IncomingContextFactory($c[BusOperations::class], $c[OutgoingOptionsFactory::class]);
         };
-        $c[OutgoingContextFactory::class] = function () {
+        $c[OutgoingContextFactory::class] = function() {
             return new OutgoingContextFactory();
         };
 
-        $c[ClockInterface::class] = function () {
+        $c[ClockInterface::class] = function() {
             return new SystemClock();
         };
-        $c[DateTimeConverter::class] = function () {
+        $c[DateTimeConverter::class] = function() {
             return new DateTimeConverter();
         };
 
-        $c[PushPipe::class] = function ($c) {
+        $c[PushPipe::class] = function($c) {
             /** @var PipelineFactory $pipelineFactory */
             $pipelineFactory = $c[PipelineFactory::class];
             return new PushPipe(
@@ -526,7 +526,7 @@ 
                 )
             );
         };
-        $c[PushSettings::class] = function () {
+        $c[PushSettings::class] = function() {
             $errorQueue = $this->settings->tryGet(KnownSettingsEnum::ERROR_QUEUE);
             if (!$errorQueue) {
                 throw new UnexpectedValueException(
@@ -539,7 +539,7 @@ 
                 $this->settings->tryGet(KnownSettingsEnum::PURGE_ON_STARTUP) ?: false
             );
         };
-        $c[TransportReceiver::class] = function ($c) {
+        $c[TransportReceiver::class] = function($c) {
             return new TransportReceiver(
                 $c[MessagePusherInterface::class],
                 $c[PushSettings::class],

src/ErrorHandling/FirstLevelRetry/FirstLevelRetryFeature.php

Spacing +3 added lines, -3 removed lines

@@ -21,13 +21,13 @@ 
     {
         $this->enableByDefault();
         $this->registerPrerequisite(
-            function (Settings $settings) {
+            function(Settings $settings) {
                 return !$settings->tryGet(KnownSettingsEnum::SEND_ONLY);
             },
             "Send only endpoints can't use FLR since it only applies to messages being received."
         );
         $this->registerPrerequisite(
-            function (Settings $settings) {
+            function(Settings $settings) {
                 return $this->getMaxRetries($settings) > 0;
             },
             "FLR was disabled in config since it's set to 0."
@@ -56,7 +56,7 @@ 
         $pipelineModifications->registerStep(
             'FirstLevelRetryPipelineStep',
             FirstLevelRetryPipelineStep::class,
-            function () use ($builder) {
+            function() use ($builder) {
                 return new FirstLevelRetryPipelineStep(
                     $builder->build(FirstLevelRetryStorage::class),
                     $builder->build(FirstLevelRetryPolicy::class)

src/ErrorHandling/ErrorLastResort/ErrorLastResortFeature.php

Spacing +3 added lines, -3 removed lines

@@ -26,7 +26,7 @@ 
     {
         $this->enableByDefault();
         $this->registerPrerequisite(
-            function (Settings $settings) {
+            function(Settings $settings) {
                 return !$settings->tryGet(KnownSettingsEnum::SEND_ONLY);
             },
             "Send only endpoints can't be used to forward received messages to the error queue as the endpoint requires receive capabilities."
@@ -56,7 +56,7 @@ 
 
         $builder->defineSingleton(
             ExceptionToHeadersConverter::class,
-            function () use ($builder) {
+            function() use ($builder) {
                 return new ExceptionToHeadersConverter(
                     $builder->build(ClockInterface::class),
                     $builder->build(DateTimeConverter::class)
@@ -67,7 +67,7 @@ 
         $registration = $pipelineModifications->registerStep(
             'MoveErrorsToErrorQueuePipelineStep',
             MoveErrorsToErrorQueuePipelineStep::class,
-            function () use ($errorQueue, $localAddress, $builder) {
+            function() use ($errorQueue, $localAddress, $builder) {
                 /** @var PipelineFactory $pipelineFactory */
                 $pipelineFactory = $builder->build(PipelineFactory::class);
                 return new MoveErrorsToErrorQueuePipelineStep(

src/ObjectBuilder/Container.php

Spacing +1 added lines, -1 removed lines

@@ -218,7 +218,7 @@
 
         $factory = $this->values[$id];
 
-        $extended = function ($c) use ($callable, $factory) {
+        $extended = function($c) use ($callable, $factory) {
             return $callable($factory($c), $c);
         };
 

src/Persistence/InMemory/InMemoryPersistenceDefinition.php

Spacing +1 added lines, -1 removed lines

@@ -30,7 +30,7 @@
     {
         $this->supports(
             StorageType::OUTBOX(),
-            function (Settings $s) {
+            function(Settings $s) {
                 FeatureSettingsExtensions::enableFeatureByDefault(
                     InMemoryOutboxPersistenceFeature::class,
                     $s