org.opendaylight.controller.cluster.common.actor

Class QuarantinedMonitorActor

java.lang.Object

akka.actor.UntypedActor

org.opendaylight.controller.cluster.common.actor.QuarantinedMonitorActor

All Implemented Interfaces:

akka.actor.Actor

public class QuarantinedMonitorActor
extends akka.actor.UntypedActor

This class listens to Akka RemotingLifecycleEvent events to detect when this node has been quarantined by another. Once this node gets quarantined, restart the ActorSystem to allow this node to rejoin the cluster.

Author:

Gary Wu gary.wu1@huawei.com

Nested Class Summary

Nested classes/interfaces inherited from interface akka.actor.Actor

akka.actor.Actor.emptyBehavior$, akka.actor.Actor.ignoringBehavior$

Field Summary

Fields

Modifier and Type	Field and Description
static String	ADDRESS

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	QuarantinedMonitorActor(akka.japi.Effect callback)

Method Summary

Modifier and Type	Method and Description
void	onReceive(Object message)
void	postStop()
static akka.actor.Props	props(akka.japi.Effect callback)

Methods inherited from class akka.actor.UntypedActor

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, getContext, getSelf, getSender, postRestart, preRestart, preStart, receive, self, sender, supervisorStrategy, unhandled

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

$init$, noSender

Field Detail

ADDRESS

public static final String ADDRESS

See Also:

Constant Field Values

Constructor Detail

QuarantinedMonitorActor

protected QuarantinedMonitorActor(akka.japi.Effect callback)

Method Detail

postStop

public void postStop()

Specified by:

postStop in interface akka.actor.Actor

Overrides:

postStop in class akka.actor.UntypedActor

onReceive

public void onReceive(Object message)
               throws Exception

Specified by:

onReceive in class akka.actor.UntypedActor

Throws:

Exception

props

public static akka.actor.Props props(akka.japi.Effect callback)