Package org.apache.pekko.cluster.pubsub

Interface DistributedPubSubMediator.Internal$.TopicLike

All Superinterfaces:

Actor

Enclosing class:

DistributedPubSubMediator.Internal$

public static interface DistributedPubSubMediator.Internal$.TopicLike
extends Actor

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.pekko.actor.Actor

Actor.emptyBehavior$, Actor.ignoringBehavior$

Method Summary

Modifier and Type	Method	Description
scala.PartialFunction<Object,scala.runtime.BoxedUnit>	business()
scala.PartialFunction<Object,scala.runtime.BoxedUnit>	defaultReceive()
scala.concurrent.duration.FiniteDuration	emptyTimeToLive()
void	org$apache$pekko$cluster$pubsub$DistributedPubSubMediator$Internal$TopicLike$_setter_$pruneInterval_$eq(scala.concurrent.duration.FiniteDuration x$1)
void	org$apache$pekko$cluster$pubsub$DistributedPubSubMediator$Internal$TopicLike$_setter_$pruneTask_$eq(Cancellable x$1)
void	postStop()	User overridable callback.
scala.Option<scala.concurrent.duration.Deadline>	pruneDeadline()
void	pruneDeadline_$eq(scala.Option<scala.concurrent.duration.Deadline> x$1)
scala.concurrent.duration.FiniteDuration	pruneInterval()
Cancellable	pruneTask()
scala.PartialFunction<Object,scala.runtime.BoxedUnit>	receive()	Scala API: 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()
void	subscribers_$eq(scala.collection.immutable.Set<ActorRef> x$1)
void	super$postStop()

Methods inherited from interface org.apache.pekko.actor.Actor

aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, org$apache$pekko$actor$Actor$_setter_$context_$eq, org$apache$pekko$actor$Actor$_setter_$self_$eq, postRestart, preRestart, preStart, self, sender, supervisorStrategy, unhandled

Method Details

business

scala.PartialFunction<Object,scala.runtime.BoxedUnit> business()

defaultReceive

scala.PartialFunction<Object,scala.runtime.BoxedUnit> defaultReceive()

emptyTimeToLive

scala.concurrent.duration.FiniteDuration emptyTimeToLive()

org$apache$pekko$cluster$pubsub$DistributedPubSubMediator$Internal$TopicLike$_setter_$pruneInterval_$eq

void org$apache$pekko$cluster$pubsub$DistributedPubSubMediator$Internal$TopicLike$_setter_$pruneInterval_$eq(scala.concurrent.duration.FiniteDuration x$1)

org$apache$pekko$cluster$pubsub$DistributedPubSubMediator$Internal$TopicLike$_setter_$pruneTask_$eq

void org$apache$pekko$cluster$pubsub$DistributedPubSubMediator$Internal$TopicLike$_setter_$pruneTask_$eq(Cancellable x$1)

postStop

void postStop()

Description copied from interface: Actor

User overridable callback.

Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.

Specified by:

postStop in interface Actor

pruneDeadline

scala.Option<scala.concurrent.duration.Deadline> pruneDeadline()

pruneDeadline_$eq

void pruneDeadline_$eq(scala.Option<scala.concurrent.duration.Deadline> x$1)

pruneInterval

scala.concurrent.duration.FiniteDuration pruneInterval()

pruneTask

Cancellable pruneTask()

receive

scala.PartialFunction<Object,scala.runtime.BoxedUnit> receive()

Description copied from interface: Actor

Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.

Specified by:

receive in interface Actor

remove

void remove(ActorRef ref)

subscribers

scala.collection.immutable.Set<ActorRef> subscribers()

subscribers_$eq

void subscribers_$eq(scala.collection.immutable.Set<ActorRef> x$1)

super$postStop

void super$postStop()