Search code examples
c#akkaactorakka.net

Retrieving Timestamp from Oracle Akka Persistence in akka.net

I am using Akka.net with oracle persistence.

Now I need to create a projection from my aggregate events and I need the timestamp on which the event occurred.

Unfortunately, I did not add this property to the event.

However, looking ate the EventJournal table used by the persistence, there is a timestamp column

enter image description here

But I cannot seem to be able to access it in a PersistentQuery stream:

 Source<EventEnvelope, NotUsed> stream =  
     PersistenceQuery
    .Get(_system)
    .ReadJournalFor<SqlReadJournal>(SqlReadJournal.Identifier)
    .EventsByTag(_myTag, 0L);

Because EventEnvelope does not have this property in it.

Does anyone knows if there is a way to get the timestamp o my projection ?

Solution

  • As of Akka net 1.4.14, a Timestamp property has been added to the EventEnvelope. So it is no longer a problem.