Package org.apache.pekko.cluster.pubsub

Class DistributedPubSubMediator.Internal$.Topic

java.lang.Object

org.apache.pekko.cluster.pubsub.DistributedPubSubMediator.Internal$.Topic

All Implemented Interfaces:

PerGroupingBuffer

Enclosing class:

DistributedPubSubMediator.Internal$

public class DistributedPubSubMediator.Internal$.Topic
extends java.lang.Object
implements PerGroupingBuffer

Constructor Summary

Constructors

Constructor	Description
Topic(scala.concurrent.duration.FiniteDuration emptyTimeToLive, RoutingLogic routingLogic)

Method Summary

Modifier and Type	Method	Description
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	business()
ActorContext	context()
scala.concurrent.duration.FiniteDuration	emptyTimeToLive()
ActorRef	newGroupActor(java.lang.String encGroup)
protected void	org$apache$pekko$actor$Actor$_setter_$context_$eq(ActorContext x$1)
protected void	org$apache$pekko$actor$Actor$_setter_$self_$eq(ActorRef x$1)
protected void	org$apache$pekko$cluster$pubsub$DistributedPubSubMediator$Internal$TopicLike$_setter_$pruneInterval_$eq(scala.concurrent.duration.FiniteDuration x$1)
protected void	org$apache$pekko$cluster$pubsub$DistributedPubSubMediator$Internal$TopicLike$_setter_$pruneTask_$eq(Cancellable x$1)
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()
ActorRef	self()
scala.collection.immutable.Set<ActorRef>	subscribers()
void	subscribers_$eq(scala.collection.immutable.Set<ActorRef> x$1)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.pekko.cluster.pubsub.PerGroupingBuffer

bufferOr, forwardMessages, forwardMessages, initializeGrouping, recreateAndForwardMessagesIfNeeded

Constructor Detail

Topic

public Topic(scala.concurrent.duration.FiniteDuration emptyTimeToLive,
             RoutingLogic routingLogic)

Method Detail

business

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

context

public ActorContext context()

emptyTimeToLive

public scala.concurrent.duration.FiniteDuration emptyTimeToLive()

newGroupActor

public ActorRef newGroupActor(java.lang.String encGroup)

org$apache$pekko$actor$Actor$_setter_$context_$eq

protected void org$apache$pekko$actor$Actor$_setter_$context_$eq(ActorContext x$1)

org$apache$pekko$actor$Actor$_setter_$self_$eq

protected final void org$apache$pekko$actor$Actor$_setter_$self_$eq(ActorRef x$1)

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

protected 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

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

pruneDeadline

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

pruneDeadline_$eq

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

pruneInterval

public scala.concurrent.duration.FiniteDuration pruneInterval()

pruneTask

public Cancellable pruneTask()

self

public final ActorRef self()

subscribers

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

subscribers_$eq

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