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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
FailureInjectorTransportAdapter
public FailureInjectorTransportAdapter(Transport wrappedTransport,
ExtendedActorSystem extendedSystem)
FailureInjectorSchemeIdentifier
public static java.lang.String FailureInjectorSchemeIdentifier()
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)