Class BarrierCoordinator

    • Constructor Detail

      • BarrierCoordinator

        public BarrierCoordinator()
    • Method Detail

      • sender

        public static final ActorRef sender()
      • aroundReceive

        protected static void aroundReceive​(scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive,
                                            java.lang.Object msg)
      • aroundPreStart

        protected static void aroundPreStart()
      • aroundPostStop

        protected static void aroundPostStop()
      • aroundPreRestart

        protected static void aroundPreRestart​(java.lang.Throwable reason,
                                               scala.Option<java.lang.Object> message)
      • aroundPostRestart

        protected static void aroundPostRestart​(java.lang.Throwable reason)
      • preStart

        public static void preStart()
                             throws java.lang.Exception
        Throws:
        java.lang.Exception
      • unhandled

        public static void unhandled​(java.lang.Object message)
      • listenerManagement

        protected static scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> listenerManagement()
      • gossip

        protected static void gossip​(java.lang.Object msg,
                                     ActorRef sender)
      • gossip$default$2

        protected static ActorRef gossip$default$2​(java.lang.Object msg)
      • akka$actor$ActorLogging$$_log

        public static LoggingAdapter akka$actor$ActorLogging$$_log()
      • akka$actor$ActorLogging$$_log_$eq

        public static void akka$actor$ActorLogging$$_log_$eq​(LoggingAdapter x$1)
      • when

        public static final void when​(S stateName,
                                      scala.concurrent.duration.FiniteDuration stateTimeout,
                                      scala.PartialFunction<FSM.Event<D>,​FSM.State<S,​D>> stateFunction)
      • when$default$2

        public static final scala.concurrent.duration.FiniteDuration when$default$2()
      • startWith

        public static final void startWith​(S stateName,
                                           D stateData,
                                           scala.Option<scala.concurrent.duration.FiniteDuration> timeout)
      • startWith$default$3

        public static final scala.Option<scala.concurrent.duration.FiniteDuration> startWith$default$3()
      • stay

        public static final FSM.State<S,​D> stay()
      • stop

        public static final FSM.State<S,​D> stop()
      • setTimer

        public static final void setTimer​(java.lang.String name,
                                          java.lang.Object msg,
                                          scala.concurrent.duration.FiniteDuration timeout,
                                          boolean repeat)
      • setTimer$default$4

        public static final boolean setTimer$default$4()
      • cancelTimer

        public static final void cancelTimer​(java.lang.String name)
      • isTimerActive

        public static final boolean isTimerActive​(java.lang.String name)
      • setStateTimeout

        public static final void setStateTimeout​(S state,
                                                 scala.Option<scala.concurrent.duration.FiniteDuration> timeout)
      • isStateTimerActive

        public static final boolean isStateTimerActive()
      • onTransition

        public static final void onTransition​(scala.PartialFunction<scala.Tuple2<S,​S>,​scala.runtime.BoxedUnit> transitionHandler)
      • total2pf

        public static final scala.PartialFunction<scala.Tuple2<S,​S>,​scala.runtime.BoxedUnit> total2pf​(scala.Function2<S,​S,​scala.runtime.BoxedUnit> transitionHandler)
      • onTermination

        public static final void onTermination​(scala.PartialFunction<FSM.StopEvent<S,​D>,​scala.runtime.BoxedUnit> terminationHandler)
      • whenUnhandled

        public static final void whenUnhandled​(scala.PartialFunction<FSM.Event<D>,​FSM.State<S,​D>> stateFunction)
      • initialize

        public static final void initialize()
      • stateName

        public static final S stateName()
      • stateData

        public static final D stateData()
      • nextStateData

        public static final D nextStateData()
      • akka$actor$FSM$$currentState

        public static FSM.State<S,​D> akka$actor$FSM$$currentState()
      • akka$actor$FSM$$currentState_$eq

        public static void akka$actor$FSM$$currentState_$eq​(FSM.State<S,​D> x$1)
      • akka$actor$FSM$$timeoutFuture

        public static scala.Option<Cancellable> akka$actor$FSM$$timeoutFuture()
      • akka$actor$FSM$$timeoutFuture_$eq

        public static void akka$actor$FSM$$timeoutFuture_$eq​(scala.Option<Cancellable> x$1)
      • akka$actor$FSM$$nextState

        public static FSM.State<S,​D> akka$actor$FSM$$nextState()
      • akka$actor$FSM$$nextState_$eq

        public static void akka$actor$FSM$$nextState_$eq​(FSM.State<S,​D> x$1)
      • akka$actor$FSM$$generation

        public static long akka$actor$FSM$$generation()
      • akka$actor$FSM$$generation_$eq

        public static void akka$actor$FSM$$generation_$eq​(long x$1)
      • akka$actor$FSM$$timers

        public static scala.collection.mutable.Map<java.lang.String,​FSM.Timer> akka$actor$FSM$$timers()
      • akka$actor$FSM$$timerGen

        public static scala.collection.Iterator<java.lang.Object> akka$actor$FSM$$timerGen()
      • akka$actor$FSM$$stateFunctions

        public static scala.collection.mutable.Map<S,​scala.PartialFunction<FSM.Event<D>,​FSM.State<S,​D>>> akka$actor$FSM$$stateFunctions()
      • akka$actor$FSM$$stateTimeouts

        public static scala.collection.mutable.Map<S,​scala.Option<scala.concurrent.duration.FiniteDuration>> akka$actor$FSM$$stateTimeouts()
      • akka$actor$FSM$$handleEventDefault

        public static scala.PartialFunction<FSM.Event<D>,​FSM.State<S,​D>> akka$actor$FSM$$handleEventDefault()
      • akka$actor$FSM$$handleEvent

        public static scala.PartialFunction<FSM.Event<D>,​FSM.State<S,​D>> akka$actor$FSM$$handleEvent()
      • akka$actor$FSM$$handleEvent_$eq

        public static void akka$actor$FSM$$handleEvent_$eq​(scala.PartialFunction<FSM.Event<D>,​FSM.State<S,​D>> x$1)
      • akka$actor$FSM$$terminateEvent

        public static scala.PartialFunction<FSM.StopEvent<S,​D>,​scala.runtime.BoxedUnit> akka$actor$FSM$$terminateEvent()
      • akka$actor$FSM$$terminateEvent_$eq

        public static void akka$actor$FSM$$terminateEvent_$eq​(scala.PartialFunction<FSM.StopEvent<S,​D>,​scala.runtime.BoxedUnit> x$1)
      • akka$actor$FSM$$transitionEvent

        public static scala.collection.immutable.List<scala.PartialFunction<scala.Tuple2<S,​S>,​scala.runtime.BoxedUnit>> akka$actor$FSM$$transitionEvent()
      • akka$actor$FSM$$transitionEvent_$eq

        public static void akka$actor$FSM$$transitionEvent_$eq​(scala.collection.immutable.List<scala.PartialFunction<scala.Tuple2<S,​S>,​scala.runtime.BoxedUnit>> x$1)
      • receive

        public static scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive()
      • applyState

        public static void applyState​(FSM.State<S,​D> nextState)
      • makeTransition

        public static void makeTransition​(FSM.State<S,​D> nextState)
      • postStop

        public static void postStop()
      • logTermination

        protected static void logTermination​(FSM.Reason reason)
      • akka$actor$FSM$_setter_$$minus$greater_$eq

        protected abstract static void akka$actor$FSM$_setter_$$minus$greater_$eq​(FSM.$minus$greater$ x$1)
      • akka$actor$FSM$_setter_$akka$actor$FSM$$timers_$eq

        protected abstract static void akka$actor$FSM$_setter_$akka$actor$FSM$$timers_$eq​(scala.collection.mutable.Map<java.lang.String,​FSM.Timer> x$1)
      • akka$actor$FSM$_setter_$akka$actor$FSM$$timerGen_$eq

        protected abstract static void akka$actor$FSM$_setter_$akka$actor$FSM$$timerGen_$eq​(scala.collection.Iterator<java.lang.Object> x$1)
      • akka$actor$FSM$_setter_$akka$actor$FSM$$stateFunctions_$eq

        protected abstract static void akka$actor$FSM$_setter_$akka$actor$FSM$$stateFunctions_$eq​(scala.collection.mutable.Map<S,​scala.PartialFunction<FSM.Event<D>,​FSM.State<S,​D>>> x$1)
      • akka$actor$FSM$_setter_$akka$actor$FSM$$stateTimeouts_$eq

        protected abstract static void akka$actor$FSM$_setter_$akka$actor$FSM$$stateTimeouts_$eq​(scala.collection.mutable.Map<S,​scala.Option<scala.concurrent.duration.FiniteDuration>> x$1)
      • akka$actor$FSM$_setter_$akka$actor$FSM$$handleEventDefault_$eq

        protected abstract static void akka$actor$FSM$_setter_$akka$actor$FSM$$handleEventDefault_$eq​(scala.PartialFunction<FSM.Event<D>,​FSM.State<S,​D>> x$1)
      • logDepth

        public static int logDepth()
      • akka$actor$LoggingFSM$$events

        public static FSM.Event<D>[] akka$actor$LoggingFSM$$events()
      • akka$actor$LoggingFSM$$states

        public static java.lang.Object[] akka$actor$LoggingFSM$$states()
      • akka$actor$LoggingFSM$$pos

        public static int akka$actor$LoggingFSM$$pos()
      • akka$actor$LoggingFSM$$pos_$eq

        public static void akka$actor$LoggingFSM$$pos_$eq​(int x$1)
      • akka$actor$LoggingFSM$$full

        public static boolean akka$actor$LoggingFSM$$full()
      • akka$actor$LoggingFSM$$full_$eq

        public static void akka$actor$LoggingFSM$$full_$eq​(boolean x$1)
      • processEvent

        public static void processEvent​(FSM.Event<D> event,
                                        java.lang.Object source)
      • getLog

        protected static scala.collection.IndexedSeq<FSM.LogEntry<S,​D>> getLog()
      • akka$actor$LoggingFSM$_setter_$akka$actor$LoggingFSM$$events_$eq

        protected abstract static void akka$actor$LoggingFSM$_setter_$akka$actor$LoggingFSM$$events_$eq​(FSM.Event<D>[] x$1)
      • akka$actor$LoggingFSM$_setter_$akka$actor$LoggingFSM$$states_$eq

        protected abstract static void akka$actor$LoggingFSM$_setter_$akka$actor$LoggingFSM$$states_$eq​(java.lang.Object[] x$1)
      • context

        public ActorContext context()
        Description copied from interface: Actor
        Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

        WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

        ActorContext is the Scala API. getContext returns a AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        context in interface Actor
        Returns:
        (undocumented)
      • self

        public final ActorRef self()
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        self in interface Actor
        Returns:
        (undocumented)
      • akka$actor$Actor$_setter_$context_$eq

        protected void akka$actor$Actor$_setter_$context_$eq​(ActorContext x$1)
        Description copied from interface: Actor
        Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

        WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

        ActorContext is the Scala API. getContext returns a AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        akka$actor$Actor$_setter_$context_$eq in interface Actor
        Parameters:
        x$1 - (undocumented)
      • akka$actor$Actor$_setter_$self_$eq

        protected final void akka$actor$Actor$_setter_$self_$eq​(ActorRef x$1)
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        akka$actor$Actor$_setter_$self_$eq in interface Actor
        Parameters:
        x$1 - (undocumented)
      • failed

        public boolean failed()
      • failed_$eq

        public void failed_$eq​(boolean x$1)
      • preRestart

        public void preRestart​(java.lang.Throwable reason,
                               scala.Option<java.lang.Object> message)
        Description copied from interface: Actor
        Scala API: User overridable callback: '''By default it disposes of all children and then calls postStop().'''
        Specified by:
        preRestart in interface Actor
        Parameters:
        reason - the Throwable that caused the restart to happen
        message - optionally the current message the actor processed when failing, if applicable

        Is called on a crashed Actor right BEFORE it is restarted to allow clean up of resources before Actor is terminated.
      • postRestart

        public void postRestart​(java.lang.Throwable reason)
        Description copied from interface: Actor
        User overridable callback: By default it calls preStart().
        Specified by:
        postRestart in interface Actor
        Parameters:
        reason - the Throwable that caused the restart to happen

        Is called right AFTER restart on the newly created Actor to allow reinitialization after an Actor crash.
      • getDeadline

        public scala.concurrent.duration.Deadline getDeadline​(scala.Option<scala.concurrent.duration.FiniteDuration> timeout)