org.maestro.worker.common.watchdog

Class DrainObserver

java.lang.Object

org.maestro.worker.common.watchdog.DrainObserver

All Implemented Interfaces:

WatchdogObserver

public class DrainObserver
extends Object
implements WatchdogObserver

Constructor Summary

Constructors

Constructor and Description
DrainObserver(WorkerOptions workerOptions, WorkerInitializer workerInitializer, MaestroReceiverClient client)

Method Summary

Modifier and Type	Method and Description
boolean	onStop(List<WorkerRuntimeInfo> workerRuntimeInfos) Actions that run on watchdog stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.maestro.worker.common.watchdog.WatchdogObserver

onStart

Constructor Detail

DrainObserver

public DrainObserver(WorkerOptions workerOptions,
                     WorkerInitializer workerInitializer,
                     MaestroReceiverClient client)

Method Detail

onStop

public boolean onStop(List<WorkerRuntimeInfo> workerRuntimeInfos)

Description copied from interface: WatchdogObserver

Actions that run on watchdog stop

Specified by:

onStop in interface WatchdogObserver

Parameters:

workerRuntimeInfos - a list of active workers and their information

Returns:

true if processing should continue or false otherwise