Package org.apache.pekko.remote.testconductor

Class TestConductorExt

java.lang.Object

org.apache.pekko.remote.testconductor.TestConductorExt

All Implemented Interfaces:

Extension, Conductor, Player

public class TestConductorExt
extends 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.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	TestConductorExt.Settings
class	TestConductorExt.Settings$

Nested classes/interfaces inherited from interface org.apache.pekko.remote.testconductor.Player

Player.Waiter

Constructor Summary

Constructors

Constructor	Description
TestConductorExt(ExtendedActorSystem system)

Method Summary

Modifier and Type	Method	Description
Address	address()	Transport address of this Netty-like remote transport.
TestConductorExt.Settings$	Settings()
ExtendedActorSystem	system()
org.apache.pekko.remote.RemoteTransport	transport()	Remote transport used by the actor ref provider.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.pekko.remote.testconductor.Conductor

_controller_$eq, abort, blackhole, controller, disconnect, exit, getNodes, passThrough, removeNode, requireTestConductorTranport, shutdown, shutdown, sockAddr, startController, throttle

Methods inherited from interface org.apache.pekko.remote.testconductor.Player

_client_$eq, client, enter, enter, getAddressFor, startClient

Constructor Details

TestConductorExt

public TestConductorExt(ExtendedActorSystem system)

Method Details

Settings

public TestConductorExt.Settings$ Settings()

address

public Address address()

Transport address of this Netty-like remote transport.

system

public ExtendedActorSystem system()

transport

public org.apache.pekko.remote.RemoteTransport transport()

Remote transport used by the actor ref provider.