diff --git a/src/Rxnet/EventStore/EventStore.php b/src/Rxnet/EventStore/EventStore.php index 162be1e..f781f42 100644 --- a/src/Rxnet/EventStore/EventStore.php +++ b/src/Rxnet/EventStore/EventStore.php @@ -413,6 +413,10 @@ public function persistentSubscription($streamID, $group) function (PersistentSubscriptionStreamEventAppeared $eventAppeared) use ($correlationID, $group) { $record = $eventAppeared->getEvent()->getEvent(); $link = $eventAppeared->getEvent()->getLink(); + if(!$record) { + // TODO ugly patch investigate why + $record = $link; + } /* @var \Rxnet\EventStore\Data\EventRecord $record */ return new AcknowledgeableEventRecord(