akka.persistence.multidc.internal

Class NotificationHotStandbySingleton

java.lang.Object

akka.persistence.multidc.internal.NotificationHotStandbySingleton

All Implemented Interfaces:

akka.actor.Extension

public class NotificationHotStandbySingleton
extends java.lang.Object
implements akka.actor.Extension

INTERNAL API

Constructor Summary

Constructors

Constructor and Description
NotificationHotStandbySingleton(akka.actor.ActorSystem system, PersistenceMultiDcSettings settings, scala.Option<akka.actor.ActorRef> instance)

Method Summary

Modifier and Type	Method and Description
static T	apply(akka.actor.ActorSystem system)
static NotificationHotStandbySingleton	createExtension(akka.actor.ExtendedActorSystem system)
static boolean	equals(java.lang.Object other)
static NotificationHotStandbySingleton	get(akka.actor.ActorSystem system)
static int	hashCode()
scala.Option<akka.actor.ActorRef>	instance()
void	loadReplicatedEventQueryJournal()
static NotificationHotStandbySingleton$	lookup()
PersistenceMultiDcSettings	settings()
akka.actor.ActorSystem	system()

Methods inherited from class java.lang.Object

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

Constructor Detail

NotificationHotStandbySingleton

public NotificationHotStandbySingleton(akka.actor.ActorSystem system,
                                       PersistenceMultiDcSettings settings,
                                       scala.Option<akka.actor.ActorRef> instance)

Method Detail

get

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

lookup

public static NotificationHotStandbySingleton$ lookup()

createExtension

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

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)

system

public akka.actor.ActorSystem system()

settings

public PersistenceMultiDcSettings settings()

instance

public scala.Option<akka.actor.ActorRef> instance()

loadReplicatedEventQueryJournal

public void loadReplicatedEventQueryJournal()