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,
ExtendedActorSystem extendedSystem) |
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() |
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, ExtendedActorSystem extendedSystem)
public static java.lang.String FailureInjectorSchemeIdentifier()
protected static java.lang.String augmentScheme(java.lang.String originalScheme)
protected static java.lang.String removeScheme(java.lang.String scheme)
protected static Transport wrappedTransport()
public static scala.concurrent.ExecutionContext ec()
public static java.lang.String schemeIdentifier()
public static boolean isResponsibleFor(Address address)
public static int maximumPayloadBytes()
public static scala.concurrent.Future<scala.Tuple2<Address,scala.concurrent.Promise<Transport.AssociationEventListener>>> listen()
public static Address boundAddress()
public static scala.concurrent.Future<AssociationHandle> associate(Address remoteAddress)
public static scala.concurrent.Future<java.lang.Object> shutdown()
public ExtendedActorSystem extendedSystem()
public java.util.concurrent.ConcurrentHashMap<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(Address listenAddress, scala.concurrent.Future<Transport.AssociationEventListener> listenerFuture)
interceptListen
in class AbstractTransportAdapter
protected void interceptAssociate(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(Address remoteAddress, java.lang.Object instance, java.lang.String debugMessage)
public boolean shouldDropOutbound(Address remoteAddress, java.lang.Object instance, java.lang.String debugMessage)
public FailureInjectorTransportAdapter.GremlinMode chaosMode(Address remoteAddress)