ghola / core

src/Routing/RoutingFeature.php

Spacing +7 added lines, -7 removed lines

@@ -47,7 +47,7 @@ 
 
         $builder->defineSingleton(
             UnicastRouterInterface::class,
-            function () use ($localAddress, $builder, $settings) {
+            function() use ($localAddress, $builder, $settings) {
                 return new UnicastRouter(
                     $localAddress,
                     $builder->build(UnicastRoutingTable::class),
@@ -59,7 +59,7 @@ 
         $pipelineModifications->registerStep(
             'UnicastSendRoutingConnector',
             UnicastSendRoutingConnector::class,
-            function () use ($builder) {
+            function() use ($builder) {
                 return new UnicastSendRoutingConnector(
                     $builder->build(UnicastRouterInterface::class),
                     $builder->build(OutgoingContextFactory::class)
@@ -69,14 +69,14 @@ 
         $pipelineModifications->registerStep(
             'UnicastReplyRoutingConnector',
             UnicastReplyRoutingConnector::class,
-            function () use ($builder) {
+            function() use ($builder) {
                 return new UnicastReplyRoutingConnector($builder->build(OutgoingContextFactory::class));
             }
         );
         $pipelineModifications->registerStep(
             'MulticastPublishRoutingConnector',
             MulticastPublishRoutingConnector::class,
-            function () use ($builder) {
+            function() use ($builder) {
                 return new MulticastPublishRoutingConnector($builder->build(OutgoingContextFactory::class));
             }
         );
@@ -86,7 +86,7 @@ 
             $pipelineModifications->registerStep(
                 'AttachReplyToAddressPipelineStep',
                 AttachReplyToAddressPipelineStep::class,
-                function () use ($localAddress) {
+                function() use ($localAddress) {
                     return new AttachReplyToAddressPipelineStep($localAddress);
                 }
             );
@@ -102,14 +102,14 @@ 
             $pipelineModifications->registerStep(
                 'SubscribeTerminator',
                 SubscribeTerminator::class,
-                function () use ($builder) {
+                function() use ($builder) {
                     return new SubscribeTerminator($builder->build(SubscriptionManagerInterface::class));
                 }
             );
             $pipelineModifications->registerStep(
                 'UnsubscribeTerminator',
                 UnsubscribeTerminator::class,
-                function () use ($builder) {
+                function() use ($builder) {
                     return new UnsubscribeTerminator($builder->build(SubscriptionManagerInterface::class));
                 }
             );

src/Routing/AutoSubscription/AutoSubscribeFeature.php

Spacing +2 added lines, -2 removed lines

@@ -16,7 +16,7 @@ 
     {
         $this->enableByDefault();
         $this->registerPrerequisite(
-            function (Settings $settings) {
+            function(Settings $settings) {
                 return !$settings->tryGet(KnownSettingsEnum::SEND_ONLY);
             },
             "Send only endpoints can't autosubscribe."
@@ -31,7 +31,7 @@ 
     public function setup(Settings $settings, BuilderInterface $builder, PipelineModifications $pipelineModifications)
     {
         $this->registerStartupTask(
-            function (BuilderInterface $builder) {
+            function(BuilderInterface $builder) {
                 /** @var MessageHandlerRegistry $handlerRegistry */
                 $handlerRegistry = $builder->build(MessageHandlerRegistry::class);
                 return new SubscriptionApplierStartupTask($handlerRegistry->getEventFqcns());

src/Pipeline/Pipeline.php

Spacing +2 added lines, -2 removed lines

@@ -40,14 +40,14 @@
         if ($step instanceof StageConnectorInterface) {
             $step->invoke(
                 $context,
-                function ($newContext) use ($currentIndex) {
+                function($newContext) use ($currentIndex) {
                     $this->invokeNext($newContext, $currentIndex + 1);
                 }
             );
         } else {
             $step->invoke(
                 $context,
-                function () use ($context, $currentIndex) {
+                function() use ($context, $currentIndex) {
                     $this->invokeNext($context, $currentIndex + 1);
                 }
             );

src/Pipeline/OutgoingPipelineFeature.php

Spacing +2 added lines, -2 removed lines

@@ -43,7 +43,7 @@ 
         $pipelineModifications->registerStep(
             'OutgoingPhysicalToDispatchConnector',
             OutgoingPhysicalToDispatchConnector::class,
-            function () use ($builder) {
+            function() use ($builder) {
                 return new OutgoingPhysicalToDispatchConnector(
                     $builder->build(OutgoingContextFactory::class),
                     $builder->build(DateTimeConverter::class),
@@ -54,7 +54,7 @@ 
         $pipelineModifications->registerStep(
             'ImmediateDispatchTerminator',
             ImmediateDispatchTerminator::class,
-            function () use ($builder) {
+            function() use ($builder) {
                 return new ImmediateDispatchTerminator($builder->build(MessageDispatcherInterface::class));
             }
         );

src/Pipeline/IncomingPipelineFeature.php

Spacing +2 added lines, -2 removed lines

@@ -39,7 +39,7 @@ 
         $pipelineModifications->registerStep(
             'LoadHandlersConnector',
             LoadHandlersConnector::class,
-            function () use ($builder) {
+            function() use ($builder) {
                 return new LoadHandlersConnector(
                     $builder->build(MessageHandlerRegistry::class),
                     $builder->build(IncomingContextFactory::class)
@@ -49,7 +49,7 @@ 
         $pipelineModifications->registerStep(
             'InvokeHandlerTerminator',
             InvokeHandlerTerminator::class,
-            function () use ($builder) {
+            function() use ($builder) {
                 return new InvokeHandlerTerminator();
             }
         );

src/Correlation/MessageCorrelationFeature.php

Spacing +1 added lines, -1 removed lines

@@ -37,7 +37,7 @@
         $pipelineModifications->registerStep(
             'AttachCorrelationIdPipelineStep',
             AttachCorrelationIdPipelineStep::class,
-            function () {
+            function() {
                 return new AttachCorrelationIdPipelineStep();
             }
         );

src/Transport/TransportFeature.php

Spacing +1 added lines, -1 removed lines

@@ -20,7 +20,7 @@
     {
         $this->enableByDefault();
         $this->registerDefault(
-            function (Settings $settings) {
+            function(Settings $settings) {
                 /** @var TransportInfrastructure $transportInfrastructure */
                 $transportInfrastructure = $settings->get(TransportInfrastructure::class);
                 $settings->setDefault(

src/Transport/ReceivingFeature.php

Spacing +2 added lines, -2 removed lines

@@ -20,7 +20,7 @@ 
         $this->enableByDefault();
         $this->dependsOn(TransportFeature::class);
         $this->registerPrerequisite(
-            function (Settings $settings) {
+            function(Settings $settings) {
                 return !$settings->tryGet(KnownSettingsEnum::SEND_ONLY);
             },
             "Endpoint is configured as send only."
@@ -50,7 +50,7 @@ 
         $builder->defineSingleton(QueueCreatorInterface::class, $receiveInfrastructure->getQueueCreatorFactory());
 
         $this->registerInstallTask(
-            function () use ($builder, $settings) {
+            function() use ($builder, $settings) {
                 return new QueueCreatorFeatureInstallTask($builder->build(QueueCreatorInterface::class), $settings);
             }
         );

src/Transport/RabbitMq/RabbitMqMessagePusher.php

Spacing +1 added lines, -1 removed lines

@@ -66,7 +66,7 @@
     {
         $this->brokerModel->consume(
             $this->pushSettings->getInputQueue(),
-            function (\AMQPEnvelope $envelope, \AMQPQueue $queue) {
+            function(\AMQPEnvelope $envelope, \AMQPQueue $queue) {
                 return $this->messageProcessor->process(
                     $envelope,
                     $queue,