Package akka.cluster.pubsub

Class DistributedPubSubMediator.Internal$.Group

java.lang.Object

akka.cluster.pubsub.DistributedPubSubMediator.Internal$.Group

Enclosing class:

DistributedPubSubMediator.Internal$

public class DistributedPubSubMediator.Internal$.Group
extends java.lang.Object

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected void	akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
protected void	akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
protected void	akka$cluster$pubsub$DistributedPubSubMediator$Internal$TopicLike$_setter_$pruneInterval_$eq(scala.concurrent.duration.FiniteDuration x$1)
protected void	akka$cluster$pubsub$DistributedPubSubMediator$Internal$TopicLike$_setter_$pruneTask_$eq(Cancellable x$1)
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	business()
ActorContext	context()
scala.concurrent.duration.FiniteDuration	emptyTimeToLive()
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

Constructor Detail

Group

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

Method Detail

akka$actor$Actor$_setter_$context_$eq

protected void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)

akka$actor$Actor$_setter_$self_$eq

protected final void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)

akka$cluster$pubsub$DistributedPubSubMediator$Internal$TopicLike$_setter_$pruneInterval_$eq

protected void akka$cluster$pubsub$DistributedPubSubMediator$Internal$TopicLike$_setter_$pruneInterval_$eq(scala.concurrent.duration.FiniteDuration x$1)

akka$cluster$pubsub$DistributedPubSubMediator$Internal$TopicLike$_setter_$pruneTask_$eq

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

business

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

context

public ActorContext context()

emptyTimeToLive

public scala.concurrent.duration.FiniteDuration emptyTimeToLive()

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)