public class Persistence
extends java.lang.Object
implements akka.actor.Extension
Modifier and Type | Class and Description |
---|---|
static class |
Persistence.PluginHolder
INTERNAL API.
|
static class |
Persistence.PluginHolder$ |
Constructor and Description |
---|
Persistence(akka.actor.ExtendedActorSystem system) |
Modifier and Type | Method and Description |
---|---|
EventAdapters |
adaptersFor(akka.actor.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(akka.actor.ActorRef journalPluginActor)
INTERNAL API
Looks up the plugin config by plugin's ActorRef.
|
static Persistence |
createExtension(akka.actor.ExtendedActorSystem system) |
static Persistence |
get(akka.actor.ActorSystem system)
Java API.
|
com.typesafe.config.Config |
journalConfigFor(java.lang.String journalPluginId)
INTERNAL API
Returns the plugin config identified by
pluginId . |
akka.actor.ActorRef |
journalFor(java.lang.String journalPluginId)
INTERNAL API
Returns a journal plugin actor identified by
journalPluginId . |
static Persistence$ |
lookup() |
java.lang.String |
persistenceId(akka.actor.ActorRef persistentActor)
Creates a canonical persistent actor id from a persistent actor ref.
|
PersistenceSettings |
settings() |
akka.actor.ActorRef |
snapshotStoreFor(java.lang.String snapshotPluginId)
INTERNAL API
|
akka.actor.ExtendedActorSystem |
system() |
public static Persistence get(akka.actor.ActorSystem system)
public static Persistence createExtension(akka.actor.ExtendedActorSystem system)
public static Persistence$ lookup()
public akka.actor.ExtendedActorSystem system()
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(akka.actor.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(akka.actor.ActorRef journalPluginActor)
journalPluginActor
- (undocumented)public final akka.actor.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 akka.actor.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(akka.actor.ActorRef persistentActor)