ghola / core

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,

src/Transport/RabbitMq/Config/RabbitMqTransportInfrastructure.php

Spacing +4 added lines, -4 removed lines

@@ -63,7 +63,7 @@ 
     public function configureSendInfrastructure()
     {
         return new TransportSendInfrastructure(
-            function () {
+            function() {
                 return new RabbitMqMessageDispatcher(
                     $this->routingTopology, $this->brokerModel, new MessageConverter()
                 );
@@ -77,13 +77,13 @@ 
     public function configureReceiveInfrastructure()
     {
         return new TransportReceiveInfrastructure(
-            function () {
+            function() {
                 return new RabbitMqMessagePusher(
                     $this->brokerModel,
                     new MessageProcessor($this->brokerModel, $this->routingTopology, new MessageConverter())
                 );
             },
-            function () {
+            function() {
                 return new RabbitMqQueueCreator(
                     $this->brokerModel,
                     $this->routingTopology,
@@ -99,7 +99,7 @@ 
     public function configureSubscriptionInfrastructure()
     {
         return new TransportSubscriptionInfrastructure(
-            function () {
+            function() {
                 return new RabbitMqSubscriptionManager(
                     $this->brokerModel,
                     $this->routingTopology,

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

src/Persistence/InMemory/Outbox/InMemoryOutboxPersistenceFeature.php

Spacing +1 added lines, -1 removed lines

@@ -38,7 +38,7 @@
         if ($outboxEnabled) {
             $builder->defineSingleton(
                 OutboxStorageInterface::class,
-                function () use ($builder, $settings) {
+                function() use ($builder, $settings) {
                     return new InMemoryOutboxStorage();
                 }
             );

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/Outbox/OutboxFeature.php

Spacing +2 added lines, -2 removed lines

@@ -26,7 +26,7 @@ 
     {
         $this->enableByDefault();
         $this->registerPrerequisite(
-            function (Settings $settings) {
+            function(Settings $settings) {
                 return !$settings->tryGet(KnownSettingsEnum::SEND_ONLY);
             },
             "Endpoint is configured as send only."
@@ -55,7 +55,7 @@ 
         $pipelineModifications->registerStep(
             'OutboxConnector',
             OutboxConnector::class,
-            function () use ($builder) {
+            function() use ($builder) {
                 /** @var PipelineFactory $pipelineFactory */
                 $pipelineFactory = $builder->build(PipelineFactory::class);
                 return new OutboxConnector(

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(