|
@@ -76,7 +76,7 @@ discard block |
|
|
block discarded – undo |
|
76
|
76
|
$this->metadataSerializer = $metadataSerializer; |
|
77
|
77
|
$this->tableName = $tableName; |
|
78
|
78
|
$this->aggregateType = $aggregateType; |
|
79
|
|
- $this->useBinary = (bool) $useBinary; |
|
|
79
|
+ $this->useBinary = (bool)$useBinary; |
|
80
|
80
|
|
|
81
|
81
|
if ($this->useBinary && Version::compare('2.5.0') >= 0) { |
|
82
|
82
|
throw new \InvalidArgumentException( |
|
@@ -119,7 +119,7 @@ discard block |
|
|
block discarded – undo |
|
119
|
119
|
// let this move on without doing this DBAL will eventually |
|
120
|
120
|
// give us a hard time but the true reason for the problem |
|
121
|
121
|
// will be obfuscated. |
|
122
|
|
- $id = (string) $id; |
|
|
122
|
+ $id = (string)$id; |
|
123
|
123
|
|
|
124
|
124
|
$this->connection->beginTransaction(); |
|
125
|
125
|
|
|
@@ -143,7 +143,7 @@ discard block |
|
|
block discarded – undo |
|
143
|
143
|
private function insertMessage(Connection $connection, DomainMessage $domainMessage) |
|
144
|
144
|
{ |
|
145
|
145
|
$data = array( |
|
146
|
|
- 'uuid' => $this->convertIdentifierToStorageValue((string) $domainMessage->getId()), |
|
|
146
|
+ 'uuid' => $this->convertIdentifierToStorageValue((string)$domainMessage->getId()), |
|
147
|
147
|
'playhead' => $domainMessage->getPlayhead(), |
|
148
|
148
|
'metadata' => json_encode($this->metadataSerializer->serialize($domainMessage->getMetadata())), |
|
149
|
149
|
'payload' => json_encode($this->payloadSerializer->serialize($domainMessage->getPayload())), |
Please login to merge, or discard this patch.