cultuurnet / udb3-php

src/EventSourcing/DBAL/AggregateAwareDBALEventStore.php

Spacing +3 added lines, -3 removed lines

@@ -99,7 +99,7 @@ 
         $this->guardStream($eventStream);
 
         // Make the transaction more robust by using the transactional statement.
-        $this->connection->transactional(function (Connection $connection) use ($eventStream) {
+        $this->connection->transactional(function(Connection $connection) use ($eventStream) {
             try {
                 foreach ($eventStream as $domainMessage) {
                     $this->insertMessage($connection, $domainMessage);
@@ -117,7 +117,7 @@ 
     private function insertMessage(Connection $connection, DomainMessage $domainMessage)
     {
         $data = array(
-            'uuid'           => (string) $domainMessage->getId(),
+            'uuid'           => (string)$domainMessage->getId(),
             'playhead'       => $domainMessage->getPlayhead(),
             'metadata'       => json_encode($this->metadataSerializer->serialize($domainMessage->getMetadata())),
             'payload'        => json_encode($this->payloadSerializer->serialize($domainMessage->getPayload())),
@@ -211,7 +211,7 @@ 
     {
         foreach ($eventStream as $domainMessage) {
             /** @var DomainMessage $domainMessage */
-            $id = (string) $domainMessage->getId();
+            $id = (string)$domainMessage->getId();
         }
     }
 }