Package akka.routing
Interface Listeners
-
- All Known Subinterfaces:
FSM<S,D>
,LoggingFSM<S,D>
,LoggingPersistentFSM<S,D,E>
,PersistentFSM<S,D,E>
,PersistentFSMBase<S,D,E>
- All Known Implementing Classes:
AbstractFSM
,AbstractFSMWithStash
,AbstractLoggingFSM
,AbstractPersistentFSM
,AbstractPersistentFSMBase
,AbstractPersistentLoggingFSM
,BarrierCoordinator
,CircuitBreakerProxy
,ClientFSM
,ClusterSingletonManager
,ProtocolStateActor
,ReliableProxy
,ServerFSM
,ThrottledAssociation
,TimerBasedThrottler
public interface Listeners
Chain this into the receive function.def receive = listenerManagement orElse …
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
akka$routing$Listeners$_setter_$listeners_$eq(java.util.Set<ActorRef> x$1)
void
gossip(java.lang.Object msg, ActorRef sender)
Sends the supplied message to all current listeners using the provided sender() as sender.ActorRef
gossip$default$2(java.lang.Object msg)
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
listenerManagement()
Chain this into the receive function.java.util.Set<ActorRef>
listeners()
-
-
-
Method Detail
-
akka$routing$Listeners$_setter_$listeners_$eq
void akka$routing$Listeners$_setter_$listeners_$eq(java.util.Set<ActorRef> x$1)
-
gossip
void gossip(java.lang.Object msg, ActorRef sender)
Sends the supplied message to all current listeners using the provided sender() as sender.- Parameters:
msg
-sender
-
-
gossip$default$2
ActorRef gossip$default$2(java.lang.Object msg)
-
listenerManagement
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> listenerManagement()
Chain this into the receive function.def receive = listenerManagement orElse …
- Returns:
- (undocumented)
-
listeners
java.util.Set<ActorRef> listeners()
-
-