akka.remote.transport
Class ThrottledAssociation

java.lang.Object
  akka.remote.transport.ThrottledAssociation

All Implemented Interfaces:

akka.actor.Actor, akka.actor.ActorLogging, akka.actor.FSM<ThrottledAssociation.ThrottlerState,ThrottledAssociation.ThrottlerData>, akka.actor.LoggingFSM<ThrottledAssociation.ThrottlerState,ThrottledAssociation.ThrottlerData>, akka.dispatch.RequiresMessageQueue<akka.dispatch.UnboundedMessageQueueSemantics>, akka.routing.Listeners

public class ThrottledAssociation
extends java.lang.Object
implements akka.actor.Actor, akka.actor.LoggingFSM<ThrottledAssociation.ThrottlerState,ThrottledAssociation.ThrottlerData>, akka.dispatch.RequiresMessageQueue<akka.dispatch.UnboundedMessageQueueSemantics>

INTERNAL API

Nested Class Summary

static class	ThrottledAssociation.Dequeue$
static class	ThrottledAssociation.ExposedHandle
static class	ThrottledAssociation.ExposedHandle$
static class	ThrottledAssociation.FailWith
static class	ThrottledAssociation.FailWith$
static interface	ThrottledAssociation.ThrottlerData
static interface	ThrottledAssociation.ThrottlerState
static class	ThrottledAssociation.Throttling$
static class	ThrottledAssociation.Uninitialized$
static class	ThrottledAssociation.WaitExposedHandle$
static class	ThrottledAssociation.WaitMode$
static class	ThrottledAssociation.WaitModeAndUpstreamListener$
static class	ThrottledAssociation.WaitOrigin$
static class	ThrottledAssociation.WaitUpstreamListener$

Nested classes/interfaces inherited from interface akka.actor.FSM

akka.actor.FSM.$minus$greater$, akka.actor.FSM.CurrentState<S>, akka.actor.FSM.CurrentState$, akka.actor.FSM.Event<D>, akka.actor.FSM.Event$, akka.actor.FSM.Failure, akka.actor.FSM.Failure$, akka.actor.FSM.LogEntry<S,D>, akka.actor.FSM.LogEntry$, akka.actor.FSM.Normal$, akka.actor.FSM.NullFunction$, akka.actor.FSM.Reason, akka.actor.FSM.Shutdown$, akka.actor.FSM.State<S,D>, akka.actor.FSM.State$, akka.actor.FSM.StateTimeout$, akka.actor.FSM.StopEvent<S,D>, akka.actor.FSM.StopEvent$, akka.actor.FSM.SubscribeTransitionCallBack, akka.actor.FSM.SubscribeTransitionCallBack$, akka.actor.FSM.TimeoutMarker, akka.actor.FSM.TimeoutMarker$, akka.actor.FSM.Timer, akka.actor.FSM.Timer$, akka.actor.FSM.TransformHelper, akka.actor.FSM.Transition<S>, akka.actor.FSM.Transition$, akka.actor.FSM.UnsubscribeTransitionCallBack, akka.actor.FSM.UnsubscribeTransitionCallBack$

Nested classes/interfaces inherited from interface akka.actor.Actor

akka.actor.Actor.emptyBehavior$

Constructor Summary

ThrottledAssociation(akka.actor.ActorRef manager, Transport.AssociationEventListener associationHandler, AssociationHandle originalHandle, boolean inbound)

Method Summary

Transport.AssociationEventListener	associationHandler()
void	forwardOrDelay(akka.util.ByteString payload)
boolean	inbound()
ThrottlerTransportAdapter.ThrottleMode	inboundThrottleMode()
akka.actor.ActorRef	manager()
AssociationHandle	originalHandle()
void	postStop()
void	scheduleDequeue(scala.concurrent.duration.FiniteDuration delay)
scala.collection.immutable.Queue<akka.util.ByteString>	throttledMessages()
AssociationHandle.HandleEventListener	upstreamListener()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.actor.LoggingFSM

akka$actor$LoggingFSM$_setter_$akka$actor$LoggingFSM$$events_$eq, akka$actor$LoggingFSM$_setter_$akka$actor$LoggingFSM$$states_$eq, akka$actor$LoggingFSM$_setter_$debugEvent_$eq, akka$actor$LoggingFSM$$events, akka$actor$LoggingFSM$$full_$eq, akka$actor$LoggingFSM$$full, akka$actor$LoggingFSM$$pos_$eq, akka$actor$LoggingFSM$$pos, akka$actor$LoggingFSM$$states, akka$actor$LoggingFSM$$super$processEvent, debugEvent, getLog, logDepth, processEvent

Methods inherited from interface akka.actor.FSM

$minus$greater, akka$actor$FSM$_setter_$$minus$greater_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$handleEventDefault_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$stateFunctions_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$stateTimeouts_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$timerGen_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$timers_$eq, akka$actor$FSM$_setter_$Event_$eq, akka$actor$FSM$_setter_$StateTimeout_$eq, akka$actor$FSM$_setter_$StopEvent_$eq, akka$actor$FSM$$currentState_$eq, akka$actor$FSM$$currentState, akka$actor$FSM$$generation_$eq, akka$actor$FSM$$generation, akka$actor$FSM$$handleEvent_$eq, akka$actor$FSM$$handleEvent, akka$actor$FSM$$handleEventDefault, akka$actor$FSM$$nextState_$eq, akka$actor$FSM$$nextState, akka$actor$FSM$$stateFunctions, akka$actor$FSM$$stateTimeouts, akka$actor$FSM$$super$postStop, akka$actor$FSM$$terminateEvent_$eq, akka$actor$FSM$$terminateEvent, akka$actor$FSM$$timeoutFuture_$eq, akka$actor$FSM$$timeoutFuture, akka$actor$FSM$$timerGen, akka$actor$FSM$$timers, akka$actor$FSM$$transitionEvent_$eq, akka$actor$FSM$$transitionEvent, applyState, cancelTimer, Event, goto, initialize, isStateTimerActive, isTimerActive, logTermination, makeTransition, nextStateData, onTermination, onTransition, setStateTimeout, setTimer, setTimer$default$4, startWith, startWith$default$3, stateData, stateName, StateTimeout, stay, stop, stop, stop, StopEvent, total2pf, transform, when, when$default$2, whenUnhandled

Methods inherited from interface akka.actor.Actor

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preRestart, preStart, self, sender, supervisorStrategy, unhandled

Methods inherited from interface akka.routing.Listeners

akka$routing$Listeners$_setter_$listeners_$eq, gossip, gossip$default$2, listenerManagement, listeners

Methods inherited from interface akka.actor.ActorLogging

akka$actor$ActorLogging$$_log_$eq, akka$actor$ActorLogging$$_log, log

Constructor Detail

ThrottledAssociation

public ThrottledAssociation(akka.actor.ActorRef manager,
                            Transport.AssociationEventListener associationHandler,
                            AssociationHandle originalHandle,
                            boolean inbound)

Method Detail

manager

public akka.actor.ActorRef manager()

associationHandler

public Transport.AssociationEventListener associationHandler()

originalHandle

public AssociationHandle originalHandle()

inbound

public boolean inbound()

inboundThrottleMode

public ThrottlerTransportAdapter.ThrottleMode inboundThrottleMode()

throttledMessages

public scala.collection.immutable.Queue<akka.util.ByteString> throttledMessages()

upstreamListener

public AssociationHandle.HandleEventListener upstreamListener()

postStop

public void postStop()

Specified by:

postStop in interface akka.actor.Actor

Specified by:

postStop in interface akka.actor.FSM<ThrottledAssociation.ThrottlerState,ThrottledAssociation.ThrottlerData>

forwardOrDelay

public void forwardOrDelay(akka.util.ByteString payload)

scheduleDequeue

public void scheduleDequeue(scala.concurrent.duration.FiniteDuration delay)