diff --git a/akka-persistence-query/src/main/scala/akka/persistence/query/EventEnvelope.scala b/akka-persistence-query/src/main/scala/akka/persistence/query/EventEnvelope.scala index 067da8585e..684d7b9324 100644 --- a/akka-persistence-query/src/main/scala/akka/persistence/query/EventEnvelope.scala +++ b/akka-persistence-query/src/main/scala/akka/persistence/query/EventEnvelope.scala @@ -18,7 +18,7 @@ object EventEnvelope extends AbstractFunction4[Offset, String, Long, Any, EventE new EventEnvelope(offset, persistenceId, sequenceNr, event) def unapply(arg: EventEnvelope): Option[(Offset, String, Long, Any)] = - Some((arg.offset, arg.persistenceId, arg.sequenceNr, arg.timestamp)) + Some((arg.offset, arg.persistenceId, arg.sequenceNr, arg.event)) }