phpservicebus / persistence-doctrine2

src/Doctrine2PersistenceDefinition.php

Spacing +1 added lines, -1 removed lines

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

src/Outbox/Doctrine2OutboxPersistenceFeature.php

Spacing +6 added lines, -6 removed lines

@@ -27,7 +27,7 @@ 
     {
         $this->dependsOn(OutboxFeature::class);
         $this->registerDefault(
-            function (Settings $settings) {
+            function(Settings $settings) {
                 $settings->setDefault(Doctrine2KnownSettingsEnum::OUTBOX_MESSAGES_TABLE_NAME, 'psb_outbox_messages');
                 $settings->setDefault(Doctrine2KnownSettingsEnum::OUTBOX_ENDPOINTS_TABLE_NAME, 'psb_outbox_endpoints');
             }
@@ -49,7 +49,7 @@ 
 
         $builder->defineSingleton(
             OutboxPersister::class,
-            function () use ($builder, $settings) {
+            function() use ($builder, $settings) {
                 return new OutboxPersister(
                     $builder->build(Connection::class),
                     $settings->get(Doctrine2KnownSettingsEnum::OUTBOX_MESSAGES_TABLE_NAME),
@@ -60,7 +60,7 @@ 
 
         $builder->defineSingleton(
             OutboxStorageInterface::class,
-            function () use ($builder, $settings) {
+            function() use ($builder, $settings) {
                 return new Doctrine2OutboxStorage(
                     $builder->build(OutboxPersister::class),
                     new OutboxMessageConverter(),
@@ -70,7 +70,7 @@ 
         );
 
         $this->registerStartupTask(
-            function () use ($builder, $settings) {
+            function() use ($builder, $settings) {
                 return new EndpointIdLoaderFeatureStartupTask(
                     $builder->build(OutboxPersister::class),
                     $settings,
@@ -80,7 +80,7 @@ 
         );
 
         $this->registerStartupTask(
-            function () use ($builder, $settings) {
+            function() use ($builder, $settings) {
                 return new OutboxCleanerFeatureStartupTask(
                     $builder->build(OutboxPersister::class),
                     new \DateTime('now', new \DateTimeZone('UTC')),
@@ -90,7 +90,7 @@ 
         );
 
         $this->registerInstallTask(
-            function () use ($builder, $settings) {
+            function() use ($builder, $settings) {
                 return new OutboxTablesCreatorFeatureInstallTask(
                     new SingleDatabaseSynchronizer($builder->build(Connection::class)),
                     new OutboxEndpointSchemaProvider(),

src/Outbox/OutboxPersister.php

Spacing +2 added lines, -2 removed lines

@@ -81,7 +81,7 @@ 
         $outboxRecord['is_dispatched'] = 0;
 
         $this->connection->transactional(
-            function (Connection $connection) use ($outboxRecord) {
+            function(Connection $connection) use ($outboxRecord) {
                 $connection->insert($this->messagesTableName, $outboxRecord);
             }
         );
@@ -199,7 +199,7 @@ 
     {
         $endpointId = 0;
         $this->connection->transactional(
-            function (Connection $connection) use ($endpointName, &$endpointId) {
+            function(Connection $connection) use ($endpointName, &$endpointId) {
                 $lookupHash = md5($endpointName);
                 $endpointRecord = $connection->executeQuery(
                     "SELECT * FROM {$this->endpointsTableName} WHERE lookup_hash = ?",