akka.persistence
Class Persistence

java.lang.Object
  extended by akka.persistence.Persistence
All Implemented Interfaces:
Extension

public class Persistence
extends java.lang.Object
implements Extension

Persistence extension.


Constructor Summary
Persistence(ExtendedActorSystem system)
           
 
Method Summary
 java.lang.String channelId(ActorRef channel)
          Creates a canonical channel id from a channel actor ref.
static Persistence createExtension(ExtendedActorSystem system)
           
static Persistence get(ActorSystem system)
          Java API.
 ActorRef journalFor(java.lang.String processorId)
          Returns a journal for a processor identified by processorId.
static Persistence$ lookup()
           
 java.lang.String processorId(ActorRef processor)
          Creates a canonical processor id from a processor actor ref.
 PersistenceSettings settings()
           
 ActorRef snapshotStoreFor(java.lang.String processorId)
          Returns a snapshot store for a processor identified by processorId.
 ExtendedActorSystem system()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

Persistence

public Persistence(ExtendedActorSystem system)
Method Detail

get

public static Persistence get(ActorSystem system)
Java API.


createExtension

public static Persistence createExtension(ExtendedActorSystem system)

lookup

public static Persistence$ lookup()

system

public ExtendedActorSystem system()

settings

public PersistenceSettings settings()

processorId

public java.lang.String processorId(ActorRef processor)
Creates a canonical processor id from a processor actor ref.


channelId

public java.lang.String channelId(ActorRef channel)
Creates a canonical channel id from a channel actor ref.


snapshotStoreFor

public ActorRef snapshotStoreFor(java.lang.String processorId)
Returns a snapshot store for a processor identified by processorId.


journalFor

public ActorRef journalFor(java.lang.String processorId)
Returns a journal for a processor identified by processorId.