Package akka.cluster.pubsub

Class DistributedPubSubMediator.Internal$.Topic

java.lang.Object

akka.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
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()
ActorRef	newGroupActor(java.lang.String encGroup)
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 akka.cluster.pubsub.PerGroupingBuffer

bufferOr, forwardMessages, forwardMessages, initializeGrouping, recreateAndForwardMessagesIfNeeded

Constructor Detail

Topic

public Topic(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()

newGroupActor

public ActorRef newGroupActor(java.lang.String encGroup)

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)