public class FailureInjectorTransportAdapter extends AbstractTransportAdapter implements Transport.AssociationEventListener
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$ |
Transport.ActorAssociationEventListener, Transport.ActorAssociationEventListener$, Transport.AssociationEvent, Transport.AssociationEventListener, Transport.InboundAssociation, Transport.InboundAssociation$, Transport.InvalidAssociationException, Transport.InvalidAssociationException$
Constructor and Description |
---|
FailureInjectorTransportAdapter(Transport wrappedTransport,
akka.actor.ExtendedActorSystem extendedSystem) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
addedSchemeIdentifier() |
java.util.concurrent.ConcurrentHashMap<akka.actor.Address,FailureInjectorTransportAdapter.GremlinMode> |
addressChaosTable() |
FailureInjectorTransportAdapter.GremlinMode |
chaosMode(akka.actor.Address remoteAddress) |
akka.actor.ExtendedActorSystem |
extendedSystem() |
static java.lang.String |
FailureInjectorSchemeIdentifier() |
protected void |
interceptAssociate(akka.actor.Address remoteAddress,
scala.concurrent.Promise<AssociationHandle> statusPromise) |
Transport.AssociationEvent |
interceptInboundAssociation(Transport.AssociationEvent ev) |
protected scala.concurrent.Future<Transport.AssociationEventListener> |
interceptListen(akka.actor.Address listenAddress,
scala.concurrent.Future<Transport.AssociationEventListener> listenerFuture) |
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() |
void |
notify(Transport.AssociationEvent ev)
Called by the transport to notify the listener about an AssociationEvent
|
boolean |
shouldDropInbound(akka.actor.Address remoteAddress,
java.lang.Object instance,
java.lang.String debugMessage) |
boolean |
shouldDropOutbound(akka.actor.Address remoteAddress,
java.lang.Object instance,
java.lang.String debugMessage) |
associate, boundAddress, ec, isResponsibleFor, listen, maximumPayloadBytes, schemeIdentifier, shutdown, wrappedTransport
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
augmentScheme, augmentScheme, removeScheme, removeScheme
public FailureInjectorTransportAdapter(Transport wrappedTransport, akka.actor.ExtendedActorSystem extendedSystem)
public static java.lang.String FailureInjectorSchemeIdentifier()
public akka.actor.ExtendedActorSystem extendedSystem()
public java.util.concurrent.ConcurrentHashMap<akka.actor.Address,FailureInjectorTransportAdapter.GremlinMode> addressChaosTable()
public java.lang.String addedSchemeIdentifier()
addedSchemeIdentifier
in interface SchemeAugmenter
protected int maximumOverhead()
maximumOverhead
in class AbstractTransportAdapter
public scala.concurrent.Future<java.lang.Object> managementCommand(java.lang.Object cmd)
Transport
managementCommand
in interface Transport
cmd
- Command message to the transportprotected scala.concurrent.Future<Transport.AssociationEventListener> interceptListen(akka.actor.Address listenAddress, scala.concurrent.Future<Transport.AssociationEventListener> listenerFuture)
interceptListen
in class AbstractTransportAdapter
protected void interceptAssociate(akka.actor.Address remoteAddress, scala.concurrent.Promise<AssociationHandle> statusPromise)
interceptAssociate
in class AbstractTransportAdapter
public void notify(Transport.AssociationEvent ev)
Transport.AssociationEventListener
notify
in interface Transport.AssociationEventListener
ev
- The AssociationEvent of the transportpublic Transport.AssociationEvent interceptInboundAssociation(Transport.AssociationEvent ev)
public boolean shouldDropInbound(akka.actor.Address remoteAddress, java.lang.Object instance, java.lang.String debugMessage)
public boolean shouldDropOutbound(akka.actor.Address remoteAddress, java.lang.Object instance, java.lang.String debugMessage)
public FailureInjectorTransportAdapter.GremlinMode chaosMode(akka.actor.Address remoteAddress)