|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.remote.transport.AbstractTransportAdapter akka.remote.transport.ActorTransportAdapter akka.remote.transport.ThrottlerTransportAdapter
public class ThrottlerTransportAdapter
Java API: get the singleton instance
Nested Class Summary | |
---|---|
static class |
ThrottlerTransportAdapter.Blackhole$
Java API: get the singleton instance |
static interface |
ThrottlerTransportAdapter.Direction
|
static class |
ThrottlerTransportAdapter.Direction$
|
static class |
ThrottlerTransportAdapter.ForceDisassociate
Management Command to force dissocation of an address. |
static class |
ThrottlerTransportAdapter.ForceDisassociate$
|
static class |
ThrottlerTransportAdapter.ForceDisassociateAck$
|
static class |
ThrottlerTransportAdapter.SetThrottle
Java API: get the singleton instance |
static class |
ThrottlerTransportAdapter.SetThrottle$
|
static class |
ThrottlerTransportAdapter.SetThrottleAck$
|
static interface |
ThrottlerTransportAdapter.ThrottleMode
Java API: get the singleton instance |
static class |
ThrottlerTransportAdapter.TokenBucket
|
static class |
ThrottlerTransportAdapter.TokenBucket$
|
static class |
ThrottlerTransportAdapter.Unthrottled$
|
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 | |
---|---|
ThrottlerTransportAdapter(Transport _wrappedTransport,
ExtendedActorSystem _system)
|
Method Summary | |
---|---|
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 Props |
managerProps()
|
protected int |
maximumOverhead()
|
static java.lang.String |
SchemeIdentifier()
|
static java.util.concurrent.atomic.AtomicInteger |
UniqueId()
|
Methods inherited from class akka.remote.transport.ActorTransportAdapter |
---|
AskTimeout, interceptAssociate, interceptListen, manager, shutdown |
Methods inherited from class akka.remote.transport.AbstractTransportAdapter |
---|
associate, ec, isResponsibleFor, listen, maximumPayloadBytes, schemeIdentifier, 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 |
---|
public ThrottlerTransportAdapter(Transport _wrappedTransport, ExtendedActorSystem _system)
Method Detail |
---|
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 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
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |