public class ThrottledAssociation extends java.lang.Object implements akka.actor.Actor, akka.actor.LoggingFSM<ThrottledAssociation.ThrottlerState,ThrottledAssociation.ThrottlerData>, akka.dispatch.RequiresMessageQueue<akka.dispatch.UnboundedMessageQueueSemantics>
Modifier and Type | Class and Description |
---|---|
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$ |
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.SilentState<S,D>, 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$
Constructor and Description |
---|
ThrottledAssociation(akka.actor.ActorRef manager,
Transport.AssociationEventListener associationHandler,
AssociationHandle originalHandle,
boolean inbound) |
Modifier and Type | Method and Description |
---|---|
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() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
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, debugEvent, getLog, logDepth, processEvent
$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$$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
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
public ThrottledAssociation(akka.actor.ActorRef manager, Transport.AssociationEventListener associationHandler, AssociationHandle originalHandle, boolean inbound)
public akka.actor.ActorRef manager()
public Transport.AssociationEventListener associationHandler()
public AssociationHandle originalHandle()
public boolean inbound()
public ThrottlerTransportAdapter.ThrottleMode inboundThrottleMode()
public scala.collection.immutable.Queue<akka.util.ByteString> throttledMessages()
public AssociationHandle.HandleEventListener upstreamListener()
public void postStop()
postStop
in interface akka.actor.Actor
postStop
in interface akka.actor.FSM<ThrottledAssociation.ThrottlerState,ThrottledAssociation.ThrottlerData>
public void forwardOrDelay(akka.util.ByteString payload)
public void scheduleDequeue(scala.concurrent.duration.FiniteDuration delay)