public class DistributedPubSub extends java.lang.Object implements Extension
DistributedPubSubMediator
actor
with settings defined in config section akka.cluster.pub-sub
.Constructor and Description |
---|
DistributedPubSub(ExtendedActorSystem system) |
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()
|
public DistributedPubSub(ExtendedActorSystem system)
public static DistributedPubSub get(ActorSystem system)
public static DistributedPubSub$ lookup()
public static DistributedPubSub createExtension(ExtendedActorSystem system)
public boolean isTerminated()
public ActorRef mediator()