ProjectionsModule

PackageFCQRS
Transactional projections with a journal-wide, durable catch-up boundary.

Summary

NameSignatureSynopsis
startstart actor options handlerCreates an independently running projection.

start

start actor options handler
Member
Creates an independently running projection. The handler must write exclusively through the supplied connection and transaction, and await all its database work. FCQRS commits the handler's updates and contiguous journal position together. Events are processed in sequence order within each persistence ID; there is no cross-persistence-ID order. Retain journal history until it has been processed. Configured Akka event adapters are currently unsupported by this projection reader. Configure the SQL journal through HOCON; DataOptionsSetup overrides are rejected because capture and replay must be validated against the same database and mapping.

Parameters

NameTypeDescription
actorIActor
optionsTransactionalProjectionOptions
handlerDbConnection -> DbTransaction -> EventEnvelope -> Task

Returns

IProjection