Package org.apache.pekko.cluster.pubsub

Class DistributedPubSub

java.lang.Object

org.apache.pekko.cluster.pubsub.DistributedPubSub

All Implemented Interfaces:

Extension

public class DistributedPubSub
extends java.lang.Object
implements Extension

Extension that starts a DistributedPubSubMediator actor with settings defined in config section pekko.cluster.pub-sub.

Constructor Summary

Constructors

Constructor	Description
DistributedPubSub(ExtendedActorSystem system)

Method Summary

Modifier and Type	Method	Description
static T	apply(ActorSystem system)
static T	apply(ClassicActorSystemProvider system)
static DistributedPubSub	createExtension(ExtendedActorSystem system)
static boolean	equals(java.lang.Object other)
static DistributedPubSub	get(ActorSystem system)
static DistributedPubSub	get(ClassicActorSystemProvider system)
static int	hashCode()
boolean	isTerminated()	Returns true if this member is not tagged with the role configured for the mediator.
static DistributedPubSub$	lookup()
ActorRef	mediator()	The DistributedPubSubMediator

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributedPubSub

public DistributedPubSub(ExtendedActorSystem system)

Method Detail

get

public static DistributedPubSub get(ActorSystem system)

get

public static DistributedPubSub get(ClassicActorSystemProvider system)

lookup

public static DistributedPubSub$ lookup()

createExtension

public static DistributedPubSub createExtension(ExtendedActorSystem system)

apply

public static T apply(ActorSystem system)

apply

public static T apply(ClassicActorSystemProvider system)

hashCode

public static final int hashCode()

equals

public static final boolean equals(java.lang.Object other)

isTerminated

public boolean isTerminated()

Returns true if this member is not tagged with the role configured for the mediator.

mediator

public ActorRef mediator()

The DistributedPubSubMediator