akka.remote.transport
Class ThrottlerTransportAdapter

java.lang.Object
  akka.remote.transport.AbstractTransportAdapter
      akka.remote.transport.ActorTransportAdapter
          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.ForceDisassociateExplicitly Management Command to force dissocation of an address with an explicit error.
static class	ThrottlerTransportAdapter.ForceDisassociateExplicitly$
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, akka.actor.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 akka.actor.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,
                                 akka.actor.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 akka.actor.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