@@ -77,7 +77,7 @@ discard block |
||
77 | 77 | */ |
78 | 78 | public function append($id, DomainEventStream $eventStream) |
79 | 79 | { |
80 | - $id = (string)$id; //Used to thrown errors if ID will not cast to string |
|
80 | + $id = (string) $id; //Used to thrown errors if ID will not cast to string |
|
81 | 81 | |
82 | 82 | $this->db->beginTransaction(); |
83 | 83 | |
@@ -103,17 +103,17 @@ discard block |
||
103 | 103 | $this->db->table($this->eventStoreTableName) |
104 | 104 | ->insert( |
105 | 105 | [ |
106 | - 'uuid' => (string)$domainMessage->getId(), |
|
106 | + 'uuid' => (string) $domainMessage->getId(), |
|
107 | 107 | 'playhead' => $domainMessage->getPlayHead(), |
108 | 108 | 'metadata' => json_encode($this->serializer->serialize($domainMessage->getMetadata())), |
109 | 109 | 'payload' => json_encode($this->serializer->serialize($domainMessage->getPayload())), |
110 | - 'recorded_on' => (string)$domainMessage->getRecordedOn(), |
|
110 | + 'recorded_on' => (string) $domainMessage->getRecordedOn(), |
|
111 | 111 | 'type' => $domainMessage->getType(), |
112 | 112 | ] |
113 | 113 | ); |
114 | 114 | } catch (\PDOException $ex) { |
115 | 115 | if ($ex->getCode() == 23000) { |
116 | - throw new DuplicateAggregatePlayhead((string)$domainMessage->getId(), $domainMessage->getPlayHead()); |
|
116 | + throw new DuplicateAggregatePlayhead((string) $domainMessage->getId(), $domainMessage->getPlayHead()); |
|
117 | 117 | } |
118 | 118 | throw $ex; |
119 | 119 | } |