akka.remote.transport
Class ThrottlerTransportAdapter

java.lang.Object
  extended by akka.remote.transport.AbstractTransportAdapter
      extended by akka.remote.transport.ActorTransportAdapter
          extended by akka.remote.transport.ThrottlerTransportAdapter
All Implemented Interfaces:
SchemeAugmenter, Transport

public class ThrottlerTransportAdapter
extends ActorTransportAdapter

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 class akka.remote.transport.ActorTransportAdapter
ActorTransportAdapter.AssociateUnderlying, ActorTransportAdapter.AssociateUnderlying$, ActorTransportAdapter.DisassociateUnderlying, ActorTransportAdapter.DisassociateUnderlying$, ActorTransportAdapter.ListenerRegistered, ActorTransportAdapter.ListenerRegistered$, ActorTransportAdapter.ListenUnderlying, ActorTransportAdapter.ListenUnderlying$, ActorTransportAdapter.TransportOperation
 
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

ThrottlerTransportAdapter

public ThrottlerTransportAdapter(Transport _wrappedTransport,
                                 ExtendedActorSystem _system)
Method Detail

SchemeIdentifier

public static java.lang.String SchemeIdentifier()

UniqueId

public static java.util.concurrent.atomic.AtomicInteger UniqueId()

addedSchemeIdentifier

protected java.lang.String addedSchemeIdentifier()

maximumOverhead

protected int maximumOverhead()
Specified by:
maximumOverhead in class AbstractTransportAdapter

managerName

protected java.lang.String managerName()
Specified by:
managerName in class ActorTransportAdapter

managerProps

protected Props managerProps()
Specified by:
managerProps in class ActorTransportAdapter

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.

Parameters:
cmd - Command message to the transport
Returns:
Future that succeeds when the command was handled or dropped