public class ThrottlerManager extends ActorTransportAdapterManager implements ActorLogging
Modifier and Type | Class and Description |
---|---|
static class |
ThrottlerManager.AssociateResult |
static class |
ThrottlerManager.AssociateResult$ |
static class |
ThrottlerManager.Checkin |
static class |
ThrottlerManager.Checkin$ |
static class |
ThrottlerManager.Handle |
static class |
ThrottlerManager.Handle$ |
static class |
ThrottlerManager.Listener |
static class |
ThrottlerManager.Listener$ |
static class |
ThrottlerManager.ListenerAndMode |
static class |
ThrottlerManager.ListenerAndMode$ |
Actor.emptyBehavior$, Actor.ignoringBehavior$
Constructor and Description |
---|
ThrottlerManager(Transport wrappedTransport) |
Modifier and Type | Method and Description |
---|---|
protected static void |
akka$actor$Actor$_setter_$context_$eq(ActorContext x$1) |
protected static void |
akka$actor$Actor$_setter_$self_$eq(ActorRef x$1) |
static void |
akka$actor$ActorLogging$$_log_$eq(LoggingAdapter x$1) |
static LoggingAdapter |
akka$actor$ActorLogging$$_log() |
protected static void |
aroundPostRestart(java.lang.Throwable reason) |
protected static void |
aroundPostStop() |
protected static void |
aroundPreRestart(java.lang.Throwable reason,
scala.Option<java.lang.Object> message) |
protected static void |
aroundPreStart() |
protected static void |
aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive,
java.lang.Object msg) |
protected static void |
associationListener_$eq(Transport.AssociationEventListener x$1) |
protected static Transport.AssociationEventListener |
associationListener() |
static ActorContext |
context() |
protected static void |
localAddress_$eq(Address x$1) |
protected static Address |
localAddress() |
static LoggingAdapter |
log() |
protected static long |
nextId() |
static void |
postRestart(java.lang.Throwable reason) |
static void |
postStop() |
static void |
preRestart(java.lang.Throwable reason,
scala.Option<java.lang.Object> message) |
static void |
preStart() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
ready() |
static scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive() |
static ActorRef |
self() |
static ActorRef |
sender() |
static SupervisorStrategy |
supervisorStrategy() |
static void |
unhandled(java.lang.Object message) |
associationListener, context, localAddress, nextId, receive, self
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
log
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, postRestart, postStop, preRestart, preStart, sender, supervisorStrategy, unhandled
public ThrottlerManager(Transport wrappedTransport)
public static final ActorRef sender()
protected static void aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, java.lang.Object msg)
protected static void aroundPreStart()
protected static void aroundPostStop()
protected static void aroundPreRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
protected static void aroundPostRestart(java.lang.Throwable reason)
public static SupervisorStrategy supervisorStrategy()
public static void preStart() throws java.lang.Exception
java.lang.Exception
public static void postStop() throws java.lang.Exception
java.lang.Exception
public static void preRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message) throws java.lang.Exception
java.lang.Exception
public static void postRestart(java.lang.Throwable reason) throws java.lang.Exception
java.lang.Exception
public static void unhandled(java.lang.Object message)
protected static Transport.AssociationEventListener associationListener()
protected static void associationListener_$eq(Transport.AssociationEventListener x$1)
protected static Address localAddress()
protected static void localAddress_$eq(Address x$1)
protected static long nextId()
public static scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
public static ActorContext context()
public static final ActorRef self()
protected static void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
protected static final void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
public static LoggingAdapter akka$actor$ActorLogging$$_log()
public static void akka$actor$ActorLogging$$_log_$eq(LoggingAdapter x$1)
public static LoggingAdapter log()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> ready()
ready
in class ActorTransportAdapterManager