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

Listeners is a generic trait to implement listening capability on an Actor.

Use the gossip(msg) method to have it sent to the listeners.

Send Listen(self) to start listening.

Send Deafen(self) to stop listening.

Send WithListeners(fun) to traverse the current listeners.

Method Summary

Modifier and Type	Method and Description
void	gossip(java.lang.Object msg, ActorRef sender) Sends the supplied message to all current listeners using the provided sender() as sender.
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	listenerManagement() Chain this into the receive function.
java.util.Set<ActorRef>	listeners()

Method Detail

listeners

java.util.Set<ActorRef> listeners()

listenerManagement

scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> listenerManagement()

Chain this into the receive function.

 def receive = listenerManagement orElse … 

Returns:

(undocumented)

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 -