akka.remote.testconductor

Class TestConductorExt

java.lang.Object

akka.remote.testconductor.TestConductorExt

All Implemented Interfaces:

Extension, Conductor, Player

public class TestConductorExt
extends java.lang.Object
implements Extension, Conductor, Player

This binds together the Conductor and Player roles inside an Akka Extension. Please follow the aforementioned links for more information.

====Note==== This extension requires the akka.actor.provider to be a 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 and Description
class	TestConductorExt.Settings

Constructor Summary

Constructors

Constructor and Description
TestConductorExt(ExtendedActorSystem system)

Method Summary

Modifier and Type	Method and Description
Address	address() Transport address of this Netty-like remote transport.
akka.remote.testconductor.TestConductorExt.Settings$	Settings()
ExtendedActorSystem	system()
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 akka.remote.testconductor.Conductor

_controller, abort, blackhole, controller, disconnect, exit, getNodes, passThrough, removeNode, requireTestConductorTranport, shutdown, shutdown, sockAddr, startController, throttle

Methods inherited from interface akka.remote.testconductor.Player

_client, client, enter, enter, getAddressFor, startClient

Constructor Detail

TestConductorExt

public TestConductorExt(ExtendedActorSystem system)

Method Detail

system

public ExtendedActorSystem system()

Settings

public akka.remote.testconductor.TestConductorExt.Settings$ Settings()

transport

public RemoteTransport transport()

Remote transport used by the actor ref provider.

Returns:

(undocumented)

address

public Address address()

Transport address of this Netty-like remote transport.

Returns:

(undocumented)