org.apache.flink.runtime.akka

Class QuarantineMonitor

java.lang.Object

akka.actor.UntypedActor

org.apache.flink.runtime.akka.QuarantineMonitor

All Implemented Interfaces:

akka.actor.Actor

public class QuarantineMonitor
extends akka.actor.UntypedActor

The quarantine monitor subscribes to the event bus of the actor system in which it was started. It listens to AssociationErrorEvent which contain information if we got quarantined or quarantine another remote actor system. If the actor detects that the actor system has been quarantined or quarantined another system, then the QuarantineHandler is called.

IMPORTANT: The implementation if highly specific for Akka 2.3.7. With different version the quarantine state might be detected differently.

Nested Class Summary

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

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

Constructor Summary

Constructors

Constructor and Description
QuarantineMonitor(QuarantineHandler handler, org.slf4j.Logger log)

Method Summary

Modifier and Type	Method and Description
void	onReceive(Object message)
void	preStart()

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, postStop, preRestart, receive, self, sender, supervisorStrategy, unhandled

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QuarantineMonitor

public QuarantineMonitor(QuarantineHandler handler,
                         org.slf4j.Logger log)

Method Detail

preStart

public void preStart()

Specified by:

preStart in interface akka.actor.Actor

Overrides:

preStart in class akka.actor.UntypedActor

onReceive

public void onReceive(Object message)
               throws Exception

Specified by:

onReceive in class akka.actor.UntypedActor

Throws:

Exception