akka.persistence.update.scaladsl

Class JournalUpdater

java.lang.Object

akka.persistence.PersistencePlugin<JournalTransformer,JournalTransformer,UpdaterPluginProvider>

akka.persistence.update.scaladsl.JournalUpdater

All Implemented Interfaces:

akka.actor.Extension

public class JournalUpdater
extends akka.persistence.PersistencePlugin<JournalTransformer,JournalTransformer,UpdaterPluginProvider>
implements akka.actor.Extension

Nested Class Summary

Nested classes/interfaces inherited from class akka.persistence.PersistencePlugin

akka.persistence.PersistencePlugin.PluginHolder<ScalaDsl,JavaDsl>, akka.persistence.PersistencePlugin.PluginHolder$

Field Summary

Fields inherited from class akka.persistence.PersistencePlugin

akka$persistence$PersistencePlugin$$ev, akka$persistence$PersistencePlugin$$system

Constructor Summary

Constructors

Constructor and Description
JournalUpdater(akka.actor.ExtendedActorSystem system)

Method Summary

Modifier and Type	Method and Description
static T	apply(akka.actor.ActorSystem system)
static JournalUpdater	createExtension(akka.actor.ExtendedActorSystem system)
static boolean	equals(java.lang.Object other)
static JournalUpdater	get(akka.actor.ActorSystem system)
<T extends JournalTransformer> T	getJournalUpdaterFor(java.lang.Class<T> clazz, java.lang.String readJournalPluginId) INTERNAL API: used by javadsl extension
static int	hashCode()
<T extends JournalTransformer> T	journalUpdaterFor(java.lang.String readJournalPluginId)
static JournalUpdater$	lookup()
static java.lang.Object	pluginProvider()

Methods inherited from class akka.persistence.PersistencePlugin

akka$persistence$PersistencePlugin$$createPlugin, akka$persistence$PersistencePlugin$$instantiate$1, pluginFor

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JournalUpdater

public JournalUpdater(akka.actor.ExtendedActorSystem system)

Method Detail

createExtension

public static JournalUpdater createExtension(akka.actor.ExtendedActorSystem system)

lookup

public static JournalUpdater$ lookup()

get

public static JournalUpdater get(akka.actor.ActorSystem system)

pluginProvider

public static java.lang.Object pluginProvider()

apply

public static T apply(akka.actor.ActorSystem system)

hashCode

public static final int hashCode()

equals

public static final boolean equals(java.lang.Object other)

journalUpdaterFor

public final <T extends JournalTransformer> T journalUpdaterFor(java.lang.String readJournalPluginId)

getJournalUpdaterFor

public final <T extends JournalTransformer> T getJournalUpdaterFor(java.lang.Class<T> clazz,
                                                                   java.lang.String readJournalPluginId)

INTERNAL API: used by javadsl extension

Parameters:

clazz - (undocumented)

readJournalPluginId - (undocumented)

Returns:

(undocumented)