@@ -104,6 +104,9 @@ discard block |
||
| 104 | 104 | } |
| 105 | 105 | } |
| 106 | 106 | |
| 107 | + /** |
|
| 108 | + * @param DomainEvent $object |
|
| 109 | + */ |
|
| 107 | 110 | private function serializePayload(\ReflectionProperty $property, $object, array $result = []) |
| 108 | 111 | { |
| 109 | 112 | $property->setAccessible(true); |
@@ -123,6 +126,9 @@ discard block |
||
| 123 | 126 | return $result; |
| 124 | 127 | } |
| 125 | 128 | |
| 129 | + /** |
|
| 130 | + * @param DomainEvent $object |
|
| 131 | + */ |
|
| 126 | 132 | private function serializeEvent(\ReflectionProperty $property, $object, array $result = []) |
| 127 | 133 | { |
| 128 | 134 | $property->setAccessible(true); |
@@ -9,7 +9,7 @@ |
||
| 9 | 9 | * file that was distributed with this source code. |
| 10 | 10 | */ |
| 11 | 11 | |
| 12 | -declare(strict_types=1); |
|
| 12 | +declare(strict_types = 1); |
|
| 13 | 13 | |
| 14 | 14 | namespace LIN3S\SharedKernel\Infrastructure\Routing\Symfony; |
| 15 | 15 | |
@@ -79,7 +79,7 @@ discard block |
||
| 79 | 79 | ORDER BY `order` ASC |
| 80 | 80 | LIMIT $limit |
| 81 | 81 | OFFSET $offset |
| 82 | -SQL; |
|
| 82 | +sql; |
|
| 83 | 83 | |
| 84 | 84 | $storedEventRows = $this->pdo->query($sql, ['occurredOn' => $since]); |
| 85 | 85 | $storedEvents = $this->buildStoredEvents($storedEventRows); |
@@ -164,7 +164,7 @@ discard block |
||
| 164 | 164 | `stream_version` INT NOT NULL, |
| 165 | 165 | PRIMARY KEY (`order`) |
| 166 | 166 | ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin; |
| 167 | -SQL; |
|
| 167 | +sql; |
|
| 168 | 168 | } |
| 169 | 169 | |
| 170 | 170 | public static function removeSchema() : string |
@@ -9,7 +9,7 @@ |
||
| 9 | 9 | * file that was distributed with this source code. |
| 10 | 10 | */ |
| 11 | 11 | |
| 12 | -declare(strict_types=1); |
|
| 12 | +declare(strict_types = 1); |
|
| 13 | 13 | |
| 14 | 14 | namespace LIN3S\SharedKernel\Domain\Model; |
| 15 | 15 | |