akka.remote.transport
Class ThrottledAssociation

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

All Implemented Interfaces:

Actor, ActorLogging, FSM<ThrottledAssociation.ThrottlerState,ThrottledAssociation.ThrottlerData>, LoggingFSM<ThrottledAssociation.ThrottlerState,ThrottledAssociation.ThrottlerData>, RequiresMessageQueue<UnboundedMessageQueueSemantics>, Listeners

public class ThrottledAssociation
extends java.lang.Object
implements Actor, LoggingFSM<ThrottledAssociation.ThrottlerState,ThrottledAssociation.ThrottlerData>, RequiresMessageQueue<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

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

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

Actor.emptyBehavior$

Constructor Summary

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

Method Summary

Transport.AssociationEventListener	associationHandler()
void	forwardOrDelay(ByteString payload)
boolean	inbound()
ThrottlerTransportAdapter.ThrottleMode	inboundThrottleMode()
ActorRef	manager()
AssociationHandle	originalHandle()
void	postStop() User overridable callback.
void	scheduleDequeue(scala.concurrent.duration.FiniteDuration delay)
scala.collection.immutable.Queue<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

advance, debugEvent, events, full, getLog, logDepth, pos, processEvent, states

Methods inherited from interface akka.actor.FSM

applyState, cancelTimer, currentState, Event, generation, handleEvent, handleEventDefault, handleTransition, initialize, isStateTimerActive, isTimerActive, logTermination, makeTransition, nextState, nextStateData, onTermination, onTransition, processMsg, register, setStateTimeout, setTimer, startWith, stateData, stateFunctions, stateName, StateTimeout, stateTimeouts, stay, stop, stop, stop, StopEvent, terminate, terminateEvent, timeoutFuture, timerGen, timers, total2pf, transform, transitionEvent, when, whenUnhandled

Methods inherited from interface akka.actor.Actor

aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preRestart, preStart, self, sender, supervisorStrategy, unhandled

Methods inherited from interface akka.routing.Listeners

gossip, listenerManagement, listeners

Methods inherited from interface akka.actor.ActorLogging

_log, log

Constructor Detail

ThrottledAssociation

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

Method Detail

manager

public 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<ByteString> throttledMessages()

upstreamListener

public AssociationHandle.HandleEventListener upstreamListener()

postStop

public void postStop()

Description copied from interface: Actor

User overridable callback.

Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.

Specified by:

postStop in interface Actor

Specified by:

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

forwardOrDelay

public void forwardOrDelay(ByteString payload)

scheduleDequeue

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