Package org.apache.pekko.cluster.pubsub
package org.apache.pekko.cluster.pubsub
-
ClassDescriptionExtension that starts a
DistributedPubSubMediatoractor with settings defined in config sectionpekko.cluster.pub-sub.This actor manages a registry of actor references and replicates the entries to peer actors among all cluster nodes or a group of nodes tagged with a specific role.Scala API: Send this message to the mediator and it will reply with anIntof the number of subscribers.Reply toGetTopics.Send this message to the mediator and it will reply withDistributedPubSubMediator.CurrentTopicscontaining the names of the (currently known) registered topic names.INTERNAL APIMessages used to encode protocol to make sure that we do not send Subscribe/Unsubscribe message to child (mediator -> topic, topic -> group) during a period of transition.Marker trait for remote messages with special serializer.param: role Start the mediator on members tagged with this role.