public class DistributedPubSubMediator.Internal$.Topic extends java.lang.Object implements PerGroupingBuffer
Constructor and Description |
---|
Topic(scala.concurrent.duration.FiniteDuration emptyTimeToLive,
RoutingLogic routingLogic) |
Modifier and Type | Method and Description |
---|---|
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() |
scala.concurrent.duration.FiniteDuration |
pruneInterval() |
Cancellable |
pruneTask() |
ActorRef |
self() |
scala.collection.immutable.Set<ActorRef> |
subscribers() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
bufferOr, forwardMessages, forwardMessages, initializeGrouping, recreateAndForwardMessagesIfNeeded
public Topic(scala.concurrent.duration.FiniteDuration emptyTimeToLive, RoutingLogic routingLogic)
public scala.concurrent.duration.FiniteDuration pruneInterval()
public Cancellable pruneTask()
public scala.Option<scala.concurrent.duration.Deadline> pruneDeadline()
public scala.collection.immutable.Set<ActorRef> subscribers()
public ActorContext context()
public final ActorRef self()
public scala.concurrent.duration.FiniteDuration emptyTimeToLive()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> business()
public ActorRef newGroupActor(java.lang.String encGroup)