Package akka.cluster.pubsub
Class DistributedPubSubMediator$
- java.lang.Object
-
- akka.cluster.pubsub.DistributedPubSubMediator$
-
public class DistributedPubSubMediator$ extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description static DistributedPubSubMediator$MODULE$Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description DistributedPubSubMediator$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description DistributedPubSubMediator.CountgetCountInstance()Java API: Send this message to the mediator and it will reply with anIntegerof the number of subscribers.DistributedPubSubMediator.GetTopicsgetTopicsInstance()Java API: Send this message to the mediator and it will reply withDistributedPubSubMediator.CurrentTopicscontaining the names of the (currently known) registered topic names.Propsprops(DistributedPubSubSettings settings)Scala API: Factory method forDistributedPubSubMediatorProps.
-
-
-
Field Detail
-
MODULE$
public static final DistributedPubSubMediator$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
props
public Props props(DistributedPubSubSettings settings)
Scala API: Factory method forDistributedPubSubMediatorProps.
-
getTopicsInstance
public DistributedPubSubMediator.GetTopics getTopicsInstance()
Java API: Send this message to the mediator and it will reply withDistributedPubSubMediator.CurrentTopicscontaining the names of the (currently known) registered topic names.
-
getCountInstance
public DistributedPubSubMediator.Count getCountInstance()
Java API: Send this message to the mediator and it will reply with anIntegerof the number of subscribers.
-
-