Modifier and Type | Class and Description |
---|---|
static class |
Persistence.PluginHolder
INTERNAL API.
|
static class |
Persistence.PluginHolder$ |
Constructor and Description |
---|
Persistence(ExtendedActorSystem system) |
Modifier and Type | Method and Description |
---|---|
EventAdapters |
adaptersFor(ActorRef journalPluginActor)
INTERNAL API
Looks up
EventAdapters by journal plugin's ActorRef. |
EventAdapters |
adaptersFor(java.lang.String journalPluginId)
Returns an
EventAdapters object which serves as a per-journal collection of bound event adapters. |
com.typesafe.config.Config |
configFor(ActorRef journalPluginActor)
INTERNAL API
Looks up the plugin config by plugin's ActorRef.
|
static Persistence |
createExtension(ExtendedActorSystem system) |
StashOverflowStrategy |
defaultInternalStashOverflowStrategy() |
static Persistence |
get(ActorSystem system)
Java API.
|
com.typesafe.config.Config |
journalConfigFor(java.lang.String journalPluginId)
INTERNAL API
Returns the plugin config identified by
pluginId . |
ActorRef |
journalFor(java.lang.String journalPluginId)
INTERNAL API
Returns a journal plugin actor identified by
journalPluginId . |
static Persistence$ |
lookup() |
java.lang.String |
persistenceId(ActorRef persistentActor)
Creates a canonical persistent actor id from a persistent actor ref.
|
ActorRef |
recoveryPermitter()
INTERNAL API: When starting many persistent actors at the same time the journal
its data store is protected from being overloaded by limiting number
of recoveries that can be in progress at the same time.
|
PersistenceSettings |
settings() |
ActorRef |
snapshotStoreFor(java.lang.String snapshotPluginId)
INTERNAL API
|
ExtendedActorSystem |
system() |
public Persistence(ExtendedActorSystem system)
public static Persistence get(ActorSystem system)
public static Persistence createExtension(ExtendedActorSystem system)
public static Persistence$ lookup()
public ExtendedActorSystem system()
public ActorRef recoveryPermitter()
public StashOverflowStrategy defaultInternalStashOverflowStrategy()
public PersistenceSettings settings()
public final EventAdapters adaptersFor(java.lang.String journalPluginId)
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.journalPluginId
- (undocumented)public final EventAdapters adaptersFor(ActorRef journalPluginActor)
EventAdapters
by journal plugin's ActorRef.journalPluginActor
- (undocumented)public final com.typesafe.config.Config journalConfigFor(java.lang.String journalPluginId)
pluginId
.
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.journalPluginId
- (undocumented)public final com.typesafe.config.Config configFor(ActorRef journalPluginActor)
journalPluginActor
- (undocumented)public final ActorRef journalFor(java.lang.String journalPluginId)
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 src/main/resources/reference.conf
.journalPluginId
- (undocumented)public final ActorRef snapshotStoreFor(java.lang.String snapshotPluginId)
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 src/main/resources/reference.conf
.
snapshotPluginId
- (undocumented)public java.lang.String persistenceId(ActorRef persistentActor)