Package akka.cluster.singleton
Class ClusterSingletonProxy
- java.lang.Object
-
- akka.cluster.singleton.ClusterSingletonProxy
-
- All Implemented Interfaces:
Actor
,ActorLogging
public final class ClusterSingletonProxy extends java.lang.Object implements Actor, ActorLogging
Discard old singleton ActorRef and send a periodic message to self to identify the singleton.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
-
Constructor Summary
Constructors Constructor Description ClusterSingletonProxy(java.lang.String singletonManagerPath, ClusterSingletonProxySettings settings)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
add(Member m)
Adds new member if it has the right role.scala.math.Ordering<Member>
ageOrdering()
protected void
akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
protected void
akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
The 'self' field holds the ActorRef for this actor.MessageBuffer
buffer()
void
buffer(java.lang.Object msg)
void
buffer_$eq(MessageBuffer x$1)
void
cancelTimer()
Cluster
cluster()
ActorContext
context()
Scala API: Stores the context for this actor, including self, and sender.java.lang.String
createIdentifyId(int i)
void
handleInitial(ClusterEvent.CurrentClusterState state)
int
identifyCounter()
void
identifyCounter_$eq(int x$1)
java.lang.String
identifyId()
void
identifyId_$eq(java.lang.String x$1)
void
identifySingleton()
Discard old singleton ActorRef and send a periodic message to self to identify the singleton.scala.Option<Cancellable>
identifyTimer()
void
identifyTimer_$eq(scala.Option<Cancellable> x$1)
boolean
matchingRole(Member member)
scala.collection.immutable.SortedSet<Member>
membersByAge()
void
membersByAge_$eq(scala.collection.immutable.SortedSet<Member> x$1)
void
postStop()
User overridable callback.void
preStart()
User overridable callback.static Props
props(java.lang.String singletonManagerPath, ClusterSingletonProxySettings settings)
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
receive()
Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.void
remove(Member m)
Removes a member.ActorRef
self()
The 'self' field holds the ActorRef for this actor.void
sendBuffered()
scala.Option<ActorRef>
singleton()
void
singleton_$eq(scala.Option<ActorRef> x$1)
java.lang.String[]
singletonPath()
void
trackChange(scala.Function0<scala.runtime.BoxedUnit> block)
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface akka.actor.Actor
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, postRestart, preRestart, sender, supervisorStrategy, unhandled
-
Methods inherited from interface akka.actor.ActorLogging
_log_$eq, log
-
-
-
-
Constructor Detail
-
ClusterSingletonProxy
public ClusterSingletonProxy(java.lang.String singletonManagerPath, ClusterSingletonProxySettings settings)
-
-
Method Detail
-
props
public static Props props(java.lang.String singletonManagerPath, ClusterSingletonProxySettings settings)
-
context
public ActorContext context()
Description copied from interface:Actor
Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such asforward
.WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!
ActorContext
is the Scala API.getContext
returns aAbstractActor.ActorContext
, which is the Java API of the actor context.
-
self
public final ActorRef self()
Description copied from interface:Actor
The 'self' field holds the ActorRef for this actor. Can be used to send messages to itself:self ! message
-
akka$actor$Actor$_setter_$context_$eq
protected void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
- Specified by:
akka$actor$Actor$_setter_$context_$eq
in interfaceActor
-
akka$actor$Actor$_setter_$self_$eq
protected final void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
Description copied from interface:Actor
The 'self' field holds the ActorRef for this actor. Can be used to send messages to itself:self ! message
- Specified by:
akka$actor$Actor$_setter_$self_$eq
in interfaceActor
- Parameters:
x$1
- (undocumented)
-
singletonPath
public java.lang.String[] singletonPath()
-
identifyCounter
public int identifyCounter()
-
identifyCounter_$eq
public void identifyCounter_$eq(int x$1)
-
identifyId
public java.lang.String identifyId()
-
identifyId_$eq
public void identifyId_$eq(java.lang.String x$1)
-
createIdentifyId
public java.lang.String createIdentifyId(int i)
-
identifyTimer
public scala.Option<Cancellable> identifyTimer()
-
identifyTimer_$eq
public void identifyTimer_$eq(scala.Option<Cancellable> x$1)
-
cluster
public Cluster cluster()
-
singleton
public scala.Option<ActorRef> singleton()
-
singleton_$eq
public void singleton_$eq(scala.Option<ActorRef> x$1)
-
ageOrdering
public scala.math.Ordering<Member> ageOrdering()
-
membersByAge
public scala.collection.immutable.SortedSet<Member> membersByAge()
-
membersByAge_$eq
public void membersByAge_$eq(scala.collection.immutable.SortedSet<Member> x$1)
-
buffer
public MessageBuffer buffer()
-
buffer_$eq
public void buffer_$eq(MessageBuffer x$1)
-
preStart
public void preStart()
Description copied from interface:Actor
User overridable callback. Is called when an Actor is started. Actors are automatically started asynchronously when created. Empty default implementation.
-
postStop
public void postStop()
Description copied from interface:Actor
User overridable callback. Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.
-
cancelTimer
public void cancelTimer()
-
matchingRole
public boolean matchingRole(Member member)
-
handleInitial
public void handleInitial(ClusterEvent.CurrentClusterState state)
-
identifySingleton
public void identifySingleton()
Discard old singleton ActorRef and send a periodic message to self to identify the singleton.
-
trackChange
public void trackChange(scala.Function0<scala.runtime.BoxedUnit> block)
-
add
public void add(Member m)
Adds new member if it has the right role.- Parameters:
m
- New cluster member.
-
remove
public void remove(Member m)
Removes a member.- Parameters:
m
- Cluster member to remove.
-
receive
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Description copied from interface:Actor
Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
-
buffer
public void buffer(java.lang.Object msg)
-
sendBuffered
public void sendBuffered()
-
-