public class ActorClassificationUnsubscriber extends java.lang.Object implements Actor, Stash
Watches all actors which subscribe on the given event stream, and unsubscribes them from it when they are Terminated.
Modifier and Type | Class and Description |
---|---|
static class |
ActorClassificationUnsubscriber.Register |
static class |
ActorClassificationUnsubscriber.Register$ |
static class |
ActorClassificationUnsubscriber.Unregister |
static class |
ActorClassificationUnsubscriber.Unregister$ |
Actor.emptyBehavior$, Actor.ignoringBehavior$
Constructor and Description |
---|
ActorClassificationUnsubscriber(ManagedActorClassification bus,
boolean debug) |
Modifier and Type | Method and Description |
---|---|
void |
preStart()
User overridable callback.
|
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive()
This defines the initial actor behavior, it must return a partial function
with the actor logic.
|
static ActorRef |
start(ActorSystem system,
ManagedActorClassification bus,
boolean debug) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, self, sender, supervisorStrategy, unhandled
actorCell, capacity, clearStash, context, enqueueFirst, mailbox, prepend, self, stash, theStash, unstash, unstashAll, unstashAll
public ActorClassificationUnsubscriber(ManagedActorClassification bus, boolean debug)
public static ActorRef start(ActorSystem system, ManagedActorClassification bus, boolean debug)
public void preStart()
Actor