Class DistributedPubSubMediator.Internal$.Topic

    • 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()
      • 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()
      • subscribers

        public scala.collection.immutable.Set<ActorRef> subscribers()
      • subscribers_$eq

        public void subscribers_$eq​(scala.collection.immutable.Set<ActorRef> x$1)