Reordering Events in a Stream Due to Messaging Queues

[jcaglobant]

Hello,

I am currently saving all events from a RabbitMQ consumer (Masstransit) using MartenDB as an EventStore . However, because of this setup, the order of events is not guaranteed. Consequently, entities in MartenDB may have a different order as they were published.

Is there a way to change the internal timestamp of the events so I can modify it to reflect the publishing time? Thanks in advance.

[jcaglobant]

public class MigrationEventListener : DocumentSessionListenerBase
{
public override Task BeforeSaveChangesAsync(IDocumentSession session, CancellationToken token)
{
    var streams = session.PendingChanges.Streams();
    foreach (var stream in streams)
    {
        foreach (var e in stream.Events)
        {

            e.Timestamp = /* YOUR TIME */
        }
   }
}
}