public class DistributedPubSubMediator.Internal$.Group
extends java.lang.Object
Constructor and Description |
---|
Group(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() |
scala.Option<scala.concurrent.duration.Deadline> |
pruneDeadline() |
scala.concurrent.duration.FiniteDuration |
pruneInterval() |
Cancellable |
pruneTask() |
ActorRef |
self() |
scala.collection.immutable.Set<ActorRef> |
subscribers() |
public Group(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()