cultuurnet / udb3-php

src/EventSourcing/DBAL/AggregateAwareDBALEventStore.php

Doc Comments +1 added lines, -1 removed lines

@@ -169,7 +169,7 @@
     }
 
     /**
-     * @return mixed
+     * @return Table
      */
     public function configureTable()
     {

Spacing +4 added lines, -4 removed lines

@@ -76,7 +76,7 @@ 
         $this->metadataSerializer = $metadataSerializer;
         $this->tableName          = $tableName;
         $this->aggregateType      = $aggregateType;
-        $this->useBinary          = (bool) $useBinary;
+        $this->useBinary          = (bool)$useBinary;
 
         if ($this->useBinary && Version::compare('2.5.0') >= 0) {
             throw new \InvalidArgumentException(
@@ -119,7 +119,7 @@ 
         // let this move on without doing this DBAL will eventually
         // give us a hard time but the true reason for the problem
         // will be obfuscated.
-        $id = (string) $id;
+        $id = (string)$id;
 
         $this->connection->beginTransaction();
 
@@ -143,7 +143,7 @@ 
     private function insertMessage(Connection $connection, DomainMessage $domainMessage)
     {
         $data = array(
-            'uuid'           => $this->convertIdentifierToStorageValue((string) $domainMessage->getId()),
+            'uuid'           => $this->convertIdentifierToStorageValue((string)$domainMessage->getId()),
             'playhead'       => $domainMessage->getPlayhead(),
             'metadata'       => json_encode($this->metadataSerializer->serialize($domainMessage->getMetadata())),
             'payload'        => json_encode($this->payloadSerializer->serialize($domainMessage->getPayload())),
@@ -214,7 +214,7 @@ 
     {
         if (null === $this->loadStatement) {
             $query = 'SELECT uuid, playhead, metadata, payload, recorded_on
-                FROM ' . $this->tableName . '
+                FROM ' . $this->tableName.'
                 WHERE uuid = :uuid
                 ORDER BY playhead ASC';
             $this->loadStatement = $this->connection->prepare($query);