Class TestConductorExt

  • All Implemented Interfaces:
    Extension, Conductor, Player

    public class TestConductorExt
    extends java.lang.Object
    implements Extension, Conductor, Player
    This binds together the pekko.remote.testconductor.Conductor and pekko.remote.testconductor.Player roles inside a Pekko pekko.actor.Extension. Please follow the aforementioned links for more information.

    ====Note==== This extension requires the pekko.actor.provider to be a pekko.remote.RemoteActorRefProvider.

    To use blackhole, passThrough, and throttle you must activate the failure injector and throttler transport adapters by specifying testTransport(on = true) in your MultiNodeConfig.

    • Method Detail

      • address

        public Address address()
        Transport address of this Netty-like remote transport.
      • transport

        public org.apache.pekko.remote.RemoteTransport transport()
        Remote transport used by the actor ref provider.