Class DistributedPubSubMediator

    • Method Detail

      • context

        public ActorContext context()
        Description copied from interface: Actor
        Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

        WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

        ActorContext is the Scala API. getContext returns a AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        context in interface Actor
        Returns:
        (undocumented)
      • self

        public final ActorRef self()
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        self in interface Actor
        Returns:
        (undocumented)
      • akka$actor$Actor$_setter_$self_$eq

        protected final void akka$actor$Actor$_setter_$self_$eq​(ActorRef x$1)
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        akka$actor$Actor$_setter_$self_$eq in interface Actor
        Parameters:
        x$1 - (undocumented)
      • cluster

        public Cluster cluster()
      • removedTimeToLiveMillis

        public long removedTimeToLiveMillis()
      • pruneInterval

        public scala.concurrent.duration.FiniteDuration pruneInterval()
      • registry

        public scala.collection.immutable.Map<Address,​akka.cluster.pubsub.DistributedPubSubMediator.Internal.Bucket> registry()
      • registry_$eq

        public void registry_$eq​(scala.collection.immutable.Map<Address,​akka.cluster.pubsub.DistributedPubSubMediator.Internal.Bucket> x$1)
      • nodes

        public scala.collection.immutable.Set<Address> nodes()
      • nodes_$eq

        public void nodes_$eq​(scala.collection.immutable.Set<Address> x$1)
      • deltaCount

        public long deltaCount()
      • deltaCount_$eq

        public void deltaCount_$eq​(long x$1)
      • nextVersion

        public scala.Function0<java.lang.Object> nextVersion()
      • preStart

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

        Is called when an Actor is started. Actors are automatically started asynchronously when created. Empty default implementation.
        Specified by:
        preStart in interface Actor
      • postStop

        public 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
      • matchingRole

        public boolean matchingRole​(Member m)
      • receive

        public 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
        Returns:
        (undocumented)
      • publish

        public void publish​(java.lang.String path,
                            java.lang.Object msg,
                            boolean allButSelf)
      • publish$default$3

        public boolean publish$default$3()
      • publishToEachGroup

        public void publishToEachGroup​(java.lang.String path,
                                       java.lang.Object msg)
      • put

        public void put​(java.lang.String key,
                        scala.Option<ActorRef> valueOption)
      • getCurrentTopics

        public scala.collection.immutable.Set<java.lang.String> getCurrentTopics()
      • registerTopic

        public void registerTopic​(ActorRef ref)
      • mkKey

        public java.lang.String mkKey​(ActorRef ref)
      • mkKey

        public java.lang.String mkKey​(ActorPath path)
      • myVersions

        public scala.collection.immutable.Map<Address,​java.lang.Object> myVersions()
      • collectDelta

        public scala.collection.immutable.Iterable<akka.cluster.pubsub.DistributedPubSubMediator.Internal.Bucket> collectDelta​(scala.collection.immutable.Map<Address,​java.lang.Object> otherVersions)
      • otherHasNewerVersions

        public boolean otherHasNewerVersions​(scala.collection.immutable.Map<Address,​java.lang.Object> otherVersions)
      • gossip

        public void gossip()
        Gossip to peer nodes.
      • gossipTo

        public void gossipTo​(Address address)
      • selectRandomNode

        public scala.Option<Address> selectRandomNode​(scala.collection.immutable.IndexedSeq<Address> addresses)
      • prune

        public void prune()
      • newTopicActor

        public ActorRef newTopicActor​(java.lang.String encTopic)