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 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$ |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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 |
ThrottledAssociation
public ThrottledAssociation(ActorRef manager,
Transport.AssociationEventListener associationHandler,
AssociationHandle originalHandle,
boolean inbound)
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)