akka.persistence
Class Persistence

java.lang.Object
  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.
ActorRef	confirmationBatchingJournalForChannel(java.lang.String channelId) INTERNAL API.
static Persistence	createExtension(ExtendedActorSystem system)
ActorRef	deletionBatchingJournalForChannel(java.lang.String channelId) INTERNAL API.
static Persistence	get(ActorSystem system) Java API.
ActorRef	journalFor(java.lang.String persistenceId) Returns a journal for a processor identified by persistenceId.
static Persistence$	lookup()
java.lang.String	persistenceId(ActorRef persistentActor) Creates a canonical persistent actor id from a processor actor ref.
java.lang.String	processorId(ActorRef processor) Creates a canonical processor id from a processor actor ref.
PersistenceSettings	settings()
ActorRef	snapshotStoreFor(java.lang.String persistenceId) Returns a snapshot store for a processor identified by persistenceId.
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.

Parameters:

system - (undocumented)

Returns:

(undocumented)

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.

Parameters:

processor - (undocumented)

Returns:

(undocumented)

persistenceId

public java.lang.String persistenceId(ActorRef persistentActor)

Creates a canonical persistent actor id from a processor actor ref.

Parameters:

persistentActor - (undocumented)

Returns:

(undocumented)

channelId

public java.lang.String channelId(ActorRef channel)

Creates a canonical channel id from a channel actor ref.

Parameters:

channel - (undocumented)

Returns:

(undocumented)

snapshotStoreFor

public ActorRef snapshotStoreFor(java.lang.String persistenceId)

Returns a snapshot store for a processor identified by persistenceId.

Parameters:

persistenceId - (undocumented)

Returns:

(undocumented)

journalFor

public ActorRef journalFor(java.lang.String persistenceId)

Returns a journal for a processor identified by persistenceId.

Parameters:

persistenceId - (undocumented)

Returns:

(undocumented)

confirmationBatchingJournalForChannel

public ActorRef confirmationBatchingJournalForChannel(java.lang.String channelId)

INTERNAL API.

Parameters:

channelId - (undocumented)

Returns:

(undocumented)

deletionBatchingJournalForChannel

public ActorRef deletionBatchingJournalForChannel(java.lang.String channelId)

INTERNAL API.

Parameters:

channelId - (undocumented)

Returns:

(undocumented)