akka.remote.testconductor

Interface Player

All Known Implementing Classes:

TestConductorExt

public interface Player

The Player is the client component of the TestConductorExt extension. It registers with the Conductor’s Controller in order to participate in barriers and enable network failure injection.

Method Summary

Modifier and Type	Method and Description
ActorRef	client()
void	enter(scala.collection.Seq<java.lang.String> name) Enter the named barriers, one after the other, in the order given.
void	enter(Timeout timeout, scala.collection.immutable.Seq<java.lang.String> name) Enter the named barriers, one after the other, in the order given.
scala.concurrent.Future<Address>	getAddressFor(RoleName name) Query remote transport address of named node.
scala.concurrent.Future<Done>	startClient(RoleName name, java.net.InetSocketAddress controllerAddr) Connect to the conductor on the given port (the host is taken from setting akka.testconductor.host).

Method Detail

client

ActorRef client()

startClient

scala.concurrent.Future<Done> startClient(RoleName name,
                                          java.net.InetSocketAddress controllerAddr)

Connect to the conductor on the given port (the host is taken from setting akka.testconductor.host). The connection is made asynchronously, but you should await completion of the returned Future because that implies that all expected participants of this test have successfully connected (i.e. this is a first barrier in itself). The number of expected participants is set in Conductor.startController().

Parameters:

name - (undocumented)

controllerAddr - (undocumented)

Returns:

(undocumented)

enter

void enter(scala.collection.Seq<java.lang.String> name)

Enter the named barriers, one after the other, in the order given. Will throw an exception in case of timeouts or other errors.

Parameters:

name - (undocumented)

enter

void enter(Timeout timeout,
           scala.collection.immutable.Seq<java.lang.String> name)

Enter the named barriers, one after the other, in the order given. Will throw an exception in case of timeouts or other errors.

Parameters:

timeout - (undocumented)

name - (undocumented)

getAddressFor

scala.concurrent.Future<Address> getAddressFor(RoleName name)

Query remote transport address of named node.

Parameters:

name - (undocumented)

Returns:

(undocumented)