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.Count
getCountInstance()
Java API: Send this message to the mediator and it will reply with anInteger
of the number of subscribers.DistributedPubSubMediator.GetTopics
getTopicsInstance()
Java API: Send this message to the mediator and it will reply withDistributedPubSubMediator.CurrentTopics
containing the names of the (currently known) registered topic names.Props
props(DistributedPubSubSettings settings)
Scala API: Factory method forDistributedPubSubMediator
Props
.
-
-
-
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 forDistributedPubSubMediator
Props
.
-
getTopicsInstance
public DistributedPubSubMediator.GetTopics getTopicsInstance()
Java API: Send this message to the mediator and it will reply withDistributedPubSubMediator.CurrentTopics
containing 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 anInteger
of the number of subscribers.
-
-