Package org.apache.pekko.cluster.pubsub

Class DistributedPubSubMediator$

java.lang.Object

org.apache.pekko.cluster.pubsub.DistributedPubSubMediator$

public class DistributedPubSubMediator$
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final DistributedPubSubMediator$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
DistributedPubSubMediator$()

Method Summary

Modifier and Type	Method	Description
DistributedPubSubMediator.Count	getCountInstance()	Java API: Send this message to the mediator and it will reply with an Integer of the number of subscribers.
DistributedPubSubMediator.GetTopics	getTopicsInstance()	Java API: Send this message to the mediator and it will reply with DistributedPubSubMediator.CurrentTopics containing the names of the (currently known) registered topic names.
Props	props(DistributedPubSubSettings settings)	Scala API: Factory method for DistributedPubSubMediator pekko.actor.Props.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

MODULE$

public static final DistributedPubSubMediator$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

DistributedPubSubMediator$

public DistributedPubSubMediator$()

Method Details

props

public Props props(DistributedPubSubSettings settings)

Scala API: Factory method for DistributedPubSubMediator pekko.actor.Props.

getTopicsInstance

public DistributedPubSubMediator.GetTopics getTopicsInstance()

Java API: Send this message to the mediator and it will reply with DistributedPubSubMediator.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 an Integer of the number of subscribers.