public class DistributedPubSub
extends java.lang.Object
implements akka.actor.Extension
DistributedPubSubMediator
actor
with settings defined in config section akka.cluster.pub-sub
.Constructor and Description |
---|
DistributedPubSub(akka.actor.ExtendedActorSystem system) |
Modifier and Type | Method and Description |
---|---|
static DistributedPubSub |
createExtension(akka.actor.ExtendedActorSystem system) |
static DistributedPubSub |
get(akka.actor.ActorSystem system) |
boolean |
isTerminated()
Returns true if this member is not tagged with the role configured for the
mediator.
|
static DistributedPubSub$ |
lookup() |
akka.actor.ActorRef |
mediator()
|
public DistributedPubSub(akka.actor.ExtendedActorSystem system)
public static DistributedPubSub get(akka.actor.ActorSystem system)
public static DistributedPubSub$ lookup()
public static DistributedPubSub createExtension(akka.actor.ExtendedActorSystem system)
public boolean isTerminated()
public akka.actor.ActorRef mediator()