public class ThrottlerTransportAdapter extends ActorTransportAdapter
ActorTransportAdapter.AssociateUnderlying, ActorTransportAdapter.AssociateUnderlying$, ActorTransportAdapter.DisassociateUnderlying, ActorTransportAdapter.DisassociateUnderlying$, ActorTransportAdapter.ListenerRegistered, ActorTransportAdapter.ListenerRegistered$, ActorTransportAdapter.ListenUnderlying, ActorTransportAdapter.ListenUnderlying$, ActorTransportAdapter.TransportOperation
Transport.ActorAssociationEventListener, Transport.ActorAssociationEventListener$, Transport.AssociationEvent, Transport.AssociationEventListener, Transport.InboundAssociation, Transport.InboundAssociation$, Transport.InvalidAssociationException, Transport.InvalidAssociationException$
Constructor and Description |
---|
ThrottlerTransportAdapter(Transport _wrappedTransport,
akka.actor.ExtendedActorSystem _system) |
Modifier and Type | Method and Description |
---|---|
protected java.lang.String |
addedSchemeIdentifier() |
scala.concurrent.Future<java.lang.Object> |
managementCommand(java.lang.Object cmd)
This method allows upper layers to send management commands to the transport.
|
protected java.lang.String |
managerName() |
protected akka.actor.Props |
managerProps() |
protected int |
maximumOverhead() |
static java.lang.String |
SchemeIdentifier() |
static java.util.concurrent.atomic.AtomicInteger |
UniqueId() |
AskTimeout, interceptAssociate, interceptListen, manager, shutdown
associate, boundAddress, ec, isResponsibleFor, listen, maximumPayloadBytes, schemeIdentifier, wrappedTransport
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
augmentScheme, augmentScheme, removeScheme, removeScheme
public ThrottlerTransportAdapter(Transport _wrappedTransport, akka.actor.ExtendedActorSystem _system)
public static java.lang.String SchemeIdentifier()
public static java.util.concurrent.atomic.AtomicInteger UniqueId()
protected java.lang.String addedSchemeIdentifier()
protected int maximumOverhead()
maximumOverhead
in class AbstractTransportAdapter
protected java.lang.String managerName()
managerName
in class ActorTransportAdapter
protected akka.actor.Props managerProps()
managerProps
in class ActorTransportAdapter
public scala.concurrent.Future<java.lang.Object> managementCommand(java.lang.Object cmd)
Transport
cmd
- Command message to the transport