public static interface DistributedPubSubMediator.Internal$.TopicLike extends Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$| Modifier and Type | Method and Description |
|---|---|
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
business() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
defaultReceive() |
scala.concurrent.duration.FiniteDuration |
emptyTimeToLive() |
void |
postStop()
User overridable callback.
|
scala.Option<scala.concurrent.duration.Deadline> |
pruneDeadline() |
scala.concurrent.duration.FiniteDuration |
pruneInterval() |
Cancellable |
pruneTask() |
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.
|
void |
remove(ActorRef ref) |
scala.collection.immutable.Set<ActorRef> |
subscribers() |
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preRestart, preStart, self, sender, supervisorStrategy, unhandledscala.concurrent.duration.FiniteDuration pruneInterval()
Cancellable pruneTask()
scala.Option<scala.concurrent.duration.Deadline> pruneDeadline()
scala.collection.immutable.Set<ActorRef> subscribers()
scala.concurrent.duration.FiniteDuration emptyTimeToLive()
void postStop()
Actorscala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> defaultReceive()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> business()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Actorvoid remove(ActorRef ref)