Returns a journal for a processor identified by persistenceId
.
Creates a canonical persistent actor id from a processor actor ref.
Returns a snapshot store for a processor identified by persistenceId
.
Creates a canonical channel id from a channel actor ref.
Creates a canonical channel id from a channel actor ref.
(Since version 2.3.4) Channels will be removed. You may want to use akka.persistence.AtLeastOnceDelivery
instead.
Creates a canonical processor id from a processor actor ref.
Creates a canonical processor id from a processor actor ref.
(Since version 2.3.4) Use persistenceId
instead. Processor will be removed.
Persistence extension.