Class PersistenceExtension

Launches the Akka.Persistence runtime

Inheritance
Object
PersistenceExtension
Implements
Inherited Members
Namespace: Akka.Persistence
Assembly: Akka.Persistence.dll
Syntax
public class PersistenceExtension : IExtension

Constructors

| Improve this Doc View Source

PersistenceExtension(ExtendedActorSystem)

Creates a new Akka.Persistence extension.

Declaration
public PersistenceExtension(ExtendedActorSystem system)
Parameters
Type Name Description
ExtendedActorSystem system

The ActorSystem that will be using Akka.Persistence
Remarks

DO NOT CALL DIRECTLY. Will be instantiated automatically be Akka.Persistence actors.

Exceptions
Type Condition
NullReferenceException

This exception is thrown when the default journal plugin, journal.plugin is not configured.

Properties

| Improve this Doc View Source

DefaultInternalStashOverflowStrategy

TBD

Declaration
public IStashOverflowStrategy DefaultInternalStashOverflowStrategy { get; }
Property Value
Type Description
IStashOverflowStrategy
| Improve this Doc View Source

Settings

The Akka.Persistence settings for the journal and snapshot store

Declaration
public PersistenceSettings Settings { get; }
Property Value
Type Description
PersistenceSettings

Methods

| Improve this Doc View Source

AdaptersFor(String)

Returns an EventAdapters object which serves as a per-journal collection of bound event adapters. If no adapters are registered for a given journal the EventAdapters object will simply return the identity adapter for each class, otherwise the most specific adapter matching a given class will be returned.

Declaration
public EventAdapters AdaptersFor(string journalPluginId)
Parameters
Type Name Description
String journalPluginId

TBD
Returns
Type Description
EventAdapters

TBD
Exceptions
Type Condition
ArgumentException

This exception is thrown when either the plugin class name is undefined or the configuration path is missing.
| Improve this Doc View Source

JournalFor(String)

Returns a journal plugin actor identified by journalPluginId. When empty, looks in akka.persistence.journal.plugin to find configuration entry path. When configured, uses journalPluginId as absolute path to the journal configuration entry. Configuration entry must contain few required fields, such as class. See persistence.conf.

Declaration
public IActorRef JournalFor(string journalPluginId)
Parameters
Type Name Description
String journalPluginId

TBD
Returns
Type Description
IActorRef

TBD
Exceptions
Type Condition
ArgumentException

This exception is thrown when either the plugin class name is undefined or the configuration path is missing.
| Improve this Doc View Source

PersistenceId(IActorRef)

TBD

Declaration
public string PersistenceId(IActorRef actor)
Parameters
Type Name Description
IActorRef actor

TBD
Returns
Type Description
String

TBD
| Improve this Doc View Source

SnapshotStoreFor(String)

Returns a snapshot store plugin actor identified by snapshotPluginId. When empty, looks in akka.persistence.snapshot-store.plugin to find configuration entry path. When configured, uses snapshotPluginId as absolute path to the snapshot store configuration entry. Configuration entry must contain few required fields, such as class. See persistence.conf.

Declaration
public IActorRef SnapshotStoreFor(string snapshotPluginId)
Parameters
Type Name Description
String snapshotPluginId

TBD
Returns
Type Description
IActorRef

TBD
Exceptions
Type Condition
ArgumentException

This exception is thrown when either the plugin class name is undefined or the configuration path is missing.

Implements

Extension Methods