akka.cluster.pubsub

Class DistributedPubSub

java.lang.Object

akka.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 akka.cluster.pub-sub.

Constructor Summary

Constructors

Constructor and Description
DistributedPubSub(ExtendedActorSystem system)

Method Summary

Modifier and Type	Method and Description
static DistributedPubSub	createExtension(ExtendedActorSystem system)
static DistributedPubSub	get(ActorSystem system)
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)

lookup

public static DistributedPubSub$ lookup()

createExtension

public static DistributedPubSub createExtension(ExtendedActorSystem system)

isTerminated

public boolean isTerminated()

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

Returns:

(undocumented)

mediator

public ActorRef mediator()

The DistributedPubSubMediator

Returns:

(undocumented)