Events replay

GridDomain has events replay functionality. It is provided by AkkaEventsChronicle class.

public class AkkaEventsChronicle 
{
    public AkkaEventsChronicle(AkkaConfiguration akkaConf)
    {
    }

    IMessagesRouter Router { get; }

    void Replay<TAggregate>(Guid aggregateId, Predicate<object> eventFilter) where TAggregate : AggregateBase;
}

It will create a new actor system and load all domain events for given aggregate type \ id. After all events will be published to system transport, and can be consumed by Router subscribers. Events chronicles will work only with persisted akka journals such as sql, due to in-memory journal can not be shared between two actor systems.

Example can be found here

Most common scenario for events rebuild is to recreate read model for an aggregate due to its corruption or build logic change.

Events rebuild requires custom code running via tool to determine what exact aggregates should be rebuilded.