akka.persistence.multidc.testkit

Class ContactPoints

java.lang.Object

akka.persistence.multidc.testkit.ContactPoints

All Implemented Interfaces:

akka.actor.Extension

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
scala.concurrent.Future<java.lang.String>	address(java.lang.String clusterId)
scala.concurrent.Future<java.lang.String>	addressDefaultClusterId()
scala.concurrent.Promise<scala.collection.immutable.Map<java.lang.String,java.lang.String>>	addressPromise()
static T	apply(akka.actor.ActorSystem system)
void	completeAddressDefaultClusterId(java.lang.String address)
static ContactPoints	createExtension(akka.actor.ExtendedActorSystem system)
static boolean	equals(java.lang.Object other)
static ContactPoints	get(akka.actor.ActorSystem system)
static int	hashCode()
static ContactPoints$	lookup()
akka.actor.ExtendedActorSystem	system()

Methods inherited from class java.lang.Object

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

Constructor Detail

ContactPoints

public ContactPoints(akka.actor.ExtendedActorSystem system)

Method Detail

get

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

lookup

public static ContactPoints$ lookup()

createExtension

public static ContactPoints 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.ExtendedActorSystem system()

addressPromise

public scala.concurrent.Promise<scala.collection.immutable.Map<java.lang.String,java.lang.String>> addressPromise()

completeAddressDefaultClusterId

public void completeAddressDefaultClusterId(java.lang.String address)

addressDefaultClusterId

public scala.concurrent.Future<java.lang.String> addressDefaultClusterId()

address

public scala.concurrent.Future<java.lang.String> address(java.lang.String clusterId)