Package org.apache.pekko.cluster.pubsub

Class DistributedPubSubMediator.Internal$.Group

java.lang.Object

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

Enclosing class:

DistributedPubSubMediator.Internal$

public class DistributedPubSubMediator.Internal$.Group
extends Object

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
scala.PartialFunction<Object,scala.runtime.BoxedUnit>	business()
ActorContext	context()
scala.concurrent.duration.FiniteDuration	emptyTimeToLive()
protected void	org$apache$pekko$actor$Actor$_setter_$context_$eq(ActorContext x$1)
protected final 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()
final 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

Constructor Details

Group

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

Method Details

business

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

context

public ActorContext context()

emptyTimeToLive

public scala.concurrent.duration.FiniteDuration emptyTimeToLive()

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)