Package akka.remote.testconductor

Interface Player

  • All Known Implementing Classes:
    TestConductorExt
    public interface Player
    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().

    • 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.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_$eq

        void _client_$eq​(ActorRef x$1)

      • 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)