public class JournalUpdater extends akka.persistence.PersistencePlugin<JournalTransformer,JournalTransformer,UpdaterPluginProvider> implements akka.actor.Extension
| Constructor and Description |
|---|
JournalUpdater(akka.actor.ExtendedActorSystem system) |
| 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> |
getJournalUpdaterFor(java.lang.Class<T> clazz,
java.lang.String readJournalPluginId)
INTERNAL API: used by javadsl extension
|
static int |
hashCode() |
<T extends JournalTransformer> |
journalUpdaterFor(java.lang.String readJournalPluginId) |
static JournalUpdater$ |
lookup() |
static java.lang.Object |
pluginProvider() |
public static JournalUpdater createExtension(akka.actor.ExtendedActorSystem system)
public static JournalUpdater$ lookup()
public static JournalUpdater get(akka.actor.ActorSystem system)
public static java.lang.Object pluginProvider()
public static T apply(akka.actor.ActorSystem system)
public static final int hashCode()
public static final boolean equals(java.lang.Object other)
public final <T extends JournalTransformer> T journalUpdaterFor(java.lang.String readJournalPluginId)
public final <T extends JournalTransformer> T getJournalUpdaterFor(java.lang.Class<T> clazz, java.lang.String readJournalPluginId)
clazz - (undocumented)readJournalPluginId - (undocumented)