akka.remote.transport

Class FailureInjectorTransportAdapter

java.lang.Object

akka.remote.transport.AbstractTransportAdapter

akka.remote.transport.FailureInjectorTransportAdapter

All Implemented Interfaces:

SchemeAugmenter, Transport, Transport.AssociationEventListener

public class FailureInjectorTransportAdapter
extends AbstractTransportAdapter
implements Transport.AssociationEventListener

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FailureInjectorTransportAdapter.All
static class	FailureInjectorTransportAdapter.All$
static class	FailureInjectorTransportAdapter.Drop
static class	FailureInjectorTransportAdapter.Drop$
static interface	FailureInjectorTransportAdapter.FailureInjectorCommand
static interface	FailureInjectorTransportAdapter.GremlinMode
static class	FailureInjectorTransportAdapter.One
static class	FailureInjectorTransportAdapter.One$
static class	FailureInjectorTransportAdapter.PassThru$

Nested classes/interfaces inherited from interface akka.remote.transport.Transport

Transport.ActorAssociationEventListener, Transport.ActorAssociationEventListener$, Transport.AssociationEvent, Transport.AssociationEventListener, Transport.InboundAssociation, Transport.InboundAssociation$, Transport.InvalidAssociationException, Transport.InvalidAssociationException$

Constructor Summary

Constructors

Constructor and Description
FailureInjectorTransportAdapter(Transport wrappedTransport, ExtendedActorSystem extendedSystem)

Method Summary

Modifier and Type	Method and Description
java.lang.String	addedSchemeIdentifier()
java.util.concurrent.ConcurrentHashMap<Address,FailureInjectorTransportAdapter.GremlinMode>	addressChaosTable()
static scala.concurrent.Future<AssociationHandle>	associate(Address remoteAddress)
protected static Address	augmentScheme(Address address)
protected static java.lang.String	augmentScheme(java.lang.String originalScheme)
static Address	boundAddress()
FailureInjectorTransportAdapter.GremlinMode	chaosMode(Address remoteAddress)
static scala.concurrent.ExecutionContext	ec()
ExtendedActorSystem	extendedSystem()
static java.lang.String	FailureInjectorSchemeIdentifier()
protected void	interceptAssociate(Address remoteAddress, scala.concurrent.Promise<AssociationHandle> statusPromise)
Transport.AssociationEvent	interceptInboundAssociation(Transport.AssociationEvent ev)
protected scala.concurrent.Future<Transport.AssociationEventListener>	interceptListen(Address listenAddress, scala.concurrent.Future<Transport.AssociationEventListener> listenerFuture)
static boolean	isResponsibleFor(Address address)
static scala.concurrent.Future<scala.Tuple2<Address,scala.concurrent.Promise<Transport.AssociationEventListener>>>	listen()
scala.concurrent.Future<java.lang.Object>	managementCommand(java.lang.Object cmd) This method allows upper layers to send management commands to the transport.
protected int	maximumOverhead()
static int	maximumPayloadBytes()
void	notify(Transport.AssociationEvent ev) Called by the transport to notify the listener about an AssociationEvent
protected static Address	removeScheme(Address address)
protected static java.lang.String	removeScheme(java.lang.String scheme)
static java.lang.String	schemeIdentifier()
boolean	shouldDropInbound(Address remoteAddress, java.lang.Object instance, java.lang.String debugMessage)
boolean	shouldDropOutbound(Address remoteAddress, java.lang.Object instance, java.lang.String debugMessage)
static scala.concurrent.Future<java.lang.Object>	shutdown()
protected static Transport	wrappedTransport()

Methods inherited from class akka.remote.transport.AbstractTransportAdapter

associate, boundAddress, ec, isResponsibleFor, listen, maximumPayloadBytes, schemeIdentifier, shutdown, wrappedTransport

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.remote.transport.SchemeAugmenter

augmentScheme, augmentScheme, removeScheme, removeScheme

Constructor Detail

FailureInjectorTransportAdapter

public FailureInjectorTransportAdapter(Transport wrappedTransport,
                                       ExtendedActorSystem extendedSystem)

Method Detail

FailureInjectorSchemeIdentifier

public static java.lang.String FailureInjectorSchemeIdentifier()

augmentScheme

protected static java.lang.String augmentScheme(java.lang.String originalScheme)

augmentScheme

protected static Address augmentScheme(Address address)

removeScheme

protected static java.lang.String removeScheme(java.lang.String scheme)

removeScheme

protected static Address removeScheme(Address address)

wrappedTransport

protected static Transport wrappedTransport()

ec

public static scala.concurrent.ExecutionContext ec()

schemeIdentifier

public static java.lang.String schemeIdentifier()

isResponsibleFor

public static boolean isResponsibleFor(Address address)

maximumPayloadBytes

public static int maximumPayloadBytes()

listen

public static scala.concurrent.Future<scala.Tuple2<Address,scala.concurrent.Promise<Transport.AssociationEventListener>>> listen()

boundAddress

public static Address boundAddress()

associate

public static scala.concurrent.Future<AssociationHandle> associate(Address remoteAddress)

shutdown

public static scala.concurrent.Future<java.lang.Object> shutdown()

extendedSystem

public ExtendedActorSystem extendedSystem()

addressChaosTable

public java.util.concurrent.ConcurrentHashMap<Address,FailureInjectorTransportAdapter.GremlinMode> addressChaosTable()

addedSchemeIdentifier

public java.lang.String addedSchemeIdentifier()

Specified by:

addedSchemeIdentifier in interface SchemeAugmenter

maximumOverhead

protected int maximumOverhead()

Specified by:

maximumOverhead in class AbstractTransportAdapter

managementCommand

public scala.concurrent.Future<java.lang.Object> managementCommand(java.lang.Object cmd)

Description copied from interface: Transport

This method allows upper layers to send management commands to the transport. It is the responsibility of the sender to send appropriate commands to different transport implementations. Unknown commands will be ignored.

Specified by:

managementCommand in interface Transport

Parameters:

cmd - Command message to the transport

Returns:

Future that succeeds when the command was handled or dropped

interceptListen

protected scala.concurrent.Future<Transport.AssociationEventListener> interceptListen(Address listenAddress,
                                                                                      scala.concurrent.Future<Transport.AssociationEventListener> listenerFuture)

Specified by:

interceptListen in class AbstractTransportAdapter

interceptAssociate

protected void interceptAssociate(Address remoteAddress,
                                  scala.concurrent.Promise<AssociationHandle> statusPromise)

Specified by:

interceptAssociate in class AbstractTransportAdapter

notify

public void notify(Transport.AssociationEvent ev)

Description copied from interface: Transport.AssociationEventListener

Called by the transport to notify the listener about an AssociationEvent

Specified by:

notify in interface Transport.AssociationEventListener

Parameters:

ev - The AssociationEvent of the transport

interceptInboundAssociation

public Transport.AssociationEvent interceptInboundAssociation(Transport.AssociationEvent ev)

shouldDropInbound

public boolean shouldDropInbound(Address remoteAddress,
                                 java.lang.Object instance,
                                 java.lang.String debugMessage)

shouldDropOutbound

public boolean shouldDropOutbound(Address remoteAddress,
                                  java.lang.Object instance,
                                  java.lang.String debugMessage)

chaosMode

public FailureInjectorTransportAdapter.GremlinMode chaosMode(Address remoteAddress)