phpservicebus / persistence-doctrine1

src/Doctrine1PersistenceDefinition.php

Spacing +1 added lines, -1 removed lines

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

src/Outbox/Doctrine1OutboxPersistenceFeature.php

Spacing +6 added lines, -6 removed lines

@@ -26,7 +26,7 @@ 
     {
         $this->dependsOn(OutboxFeature::class);
         $this->registerDefault(
-            function (Settings $settings) {
+            function(Settings $settings) {
                 $settings->setDefault(Doctrine1KnownSettingsEnum::OUTBOX_MESSAGES_TABLE_NAME, 'psb_outbox_messages');
                 $settings->setDefault(Doctrine1KnownSettingsEnum::OUTBOX_ENDPOINTS_TABLE_NAME, 'psb_outbox_endpoints');
             }
@@ -48,7 +48,7 @@ 
 
         $builder->defineSingleton(
             OutboxPersister::class,
-            function () use ($builder, $settings) {
+            function() use ($builder, $settings) {
                 return new OutboxPersister(
                     $builder->build(LogicalConnection::class),
                     $settings->get(Doctrine1KnownSettingsEnum::OUTBOX_MESSAGES_TABLE_NAME),
@@ -59,7 +59,7 @@ 
 
         $builder->defineSingleton(
             OutboxStorageInterface::class,
-            function () use ($builder, $settings) {
+            function() use ($builder, $settings) {
                 return new Doctrine1OutboxStorage(
                     $builder->build(OutboxPersister::class),
                     new OutboxMessageConverter(),
@@ -69,7 +69,7 @@ 
         );
 
         $this->registerStartupTask(
-            function () use ($builder, $settings) {
+            function() use ($builder, $settings) {
                 return new EndpointIdLoaderFeatureStartupTask(
                     $builder->build(OutboxPersister::class),
                     $settings,
@@ -79,7 +79,7 @@ 
         );
 
         $this->registerStartupTask(
-            function () use ($builder, $settings) {
+            function() use ($builder, $settings) {
                 return new OutboxCleanerFeatureStartupTask(
                     $builder->build(OutboxPersister::class),
                     new \DateTime('now', new \DateTimeZone('UTC')),
@@ -89,7 +89,7 @@ 
         );
 
         $this->registerInstallTask(
-            function () use ($builder, $settings) {
+            function() use ($builder, $settings) {
                 return new OutboxTablesCreatorFeatureInstallTask(
                     $builder->build(LogicalConnection::class),
                     new OutboxEndpointSchemaProvider(),

src/Outbox/OutboxPersister.php

Spacing +3 added lines, -3 removed lines

@@ -81,7 +81,7 @@ 
         $outboxRecord['is_dispatched'] = 0;
 
         $this->connection->transactional(
-            function (LogicalConnection $connection) use ($outboxRecord) {
+            function(LogicalConnection $connection) use ($outboxRecord) {
                 $connection->insert($this->messagesTableName, $outboxRecord);
             }
         );
@@ -150,7 +150,7 @@ 
     public function rollBack()
     {
         try {
-            $this->connection->rollBack();;
+            $this->connection->rollBack(); ;
         } catch (\Exception $e) {
             throw $this->connection->reconnectIfNeeded($e);
         }
@@ -181,7 +181,7 @@ 
     {
         $endpointId = 0;
         $this->connection->transactional(
-            function (LogicalConnection $connection) use ($endpointName, &$endpointId) {
+            function(LogicalConnection $connection) use ($endpointName, &$endpointId) {
                 $lookupHash = md5($endpointName);
                 $endpointRecord = $connection->executeQuery(
                     "SELECT * FROM {$this->endpointsTableName} WHERE lookup_hash = ?",