Interface DistributedPubSubMediator.Internal$.TopicLike

    • Method Detail

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

        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

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

        scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> business()
      • defaultReceive

        scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> defaultReceive()
      • emptyTimeToLive

        scala.concurrent.duration.FiniteDuration emptyTimeToLive()
      • postStop

        void postStop()
        Description copied from interface: Actor
        User overridable callback.

        Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.
        Specified by:
        postStop in interface Actor
      • pruneDeadline

        scala.Option<scala.concurrent.duration.Deadline> pruneDeadline()
      • pruneDeadline_$eq

        void pruneDeadline_$eq​(scala.Option<scala.concurrent.duration.Deadline> x$1)
      • pruneInterval

        scala.concurrent.duration.FiniteDuration pruneInterval()
      • receive

        scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive()
        Description copied from interface: Actor
        Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
        Specified by:
        receive in interface Actor
      • subscribers

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

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

        void super$postStop()