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 ListenersChain this into the receive function.def receive = listenerManagement orElse …
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidakka$routing$Listeners$_setter_$listeners_$eq(java.util.Set<ActorRef> x$1)voidgossip(java.lang.Object msg, ActorRef sender)Sends the supplied message to all current listeners using the provided sender() as sender.ActorRefgossip$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()
-
-