Package akka.remote.testconductor
Interface Player
-
- All Known Implementing Classes:
TestConductorExt
public interface Player
The Player is the client component of theTestConductorExt
extension. It registers with theConductor
’sController
in order to participate in barriers and enable network failure injection.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static class
Player.Waiter
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
_client_$eq(ActorRef x$1)
ActorRef
client()
void
enter(Timeout timeout, scala.collection.immutable.Seq<java.lang.String> name)
Enter the named barriers, one after the other, in the order given.void
enter(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<akka.remote.testconductor.Done>
startClient(RoleName name, java.net.InetSocketAddress controllerAddr)
Connect to the conductor on the given port (the host is taken from settingakka.testconductor.host
).
-
-
-
Method Detail
-
_client_$eq
void _client_$eq(ActorRef x$1)
-
client
ActorRef client()
-
startClient
scala.concurrent.Future<akka.remote.testconductor.Done> startClient(RoleName name, java.net.InetSocketAddress controllerAddr)
Connect to the conductor on the given port (the host is taken from settingakka.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 inConductor
.startController()
.
-
enter
void enter(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.
-
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.
-
-