Package akka.cluster.pubsub

Interface Summary

Interface	Description
DistributedPubSubMediator.Internal$.ChildActorTerminationProtocol	Messages 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.
DistributedPubSubMediator.Internal$.TopicLike
DistributedPubSubMessage	Marker trait for remote messages with special serializer.
PerGroupingBuffer

Class Summary

Class	Description
DistributedPubSub	Extension that starts a DistributedPubSubMediator actor with settings defined in config section akka.cluster.pub-sub.
DistributedPubSub$
DistributedPubSubMediator	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.
DistributedPubSubMediator.Count
DistributedPubSubMediator.Count$	Scala API: Send this message to the mediator and it will reply with an Int of the number of subscribers.
DistributedPubSubMediator.CountSubscribers
DistributedPubSubMediator.CountSubscribers$
DistributedPubSubMediator.CurrentTopics	Reply to GetTopics.
DistributedPubSubMediator.CurrentTopics$
DistributedPubSubMediator.GetTopics
DistributedPubSubMediator.GetTopics$	Send this message to the mediator and it will reply with DistributedPubSubMediator.CurrentTopics containing the names of the (currently known) registered topic names.
DistributedPubSubMediator.Internal$	INTERNAL API
DistributedPubSubMediator.Publish
DistributedPubSubMediator.Publish$
DistributedPubSubMediator.Put
DistributedPubSubMediator.Put$
DistributedPubSubMediator.Remove
DistributedPubSubMediator.Remove$
DistributedPubSubMediator.Send
DistributedPubSubMediator.Send$
DistributedPubSubMediator.SendToAll
DistributedPubSubMediator.SendToAll$
DistributedPubSubMediator.Subscribe
DistributedPubSubMediator.Subscribe$
DistributedPubSubMediator.SubscribeAck
DistributedPubSubMediator.SubscribeAck$
DistributedPubSubMediator.Unsubscribe
DistributedPubSubMediator.Unsubscribe$
DistributedPubSubMediator.UnsubscribeAck
DistributedPubSubMediator.UnsubscribeAck$
DistributedPubSubMediator$
DistributedPubSubSettings	param: role Start the mediator on members tagged with this role.
DistributedPubSubSettings$