Package com.floragunn.signals.execution

Class WatchRunner

java.lang.Object

com.floragunn.signals.execution.WatchRunner

All Implemented Interfaces:

org.quartz.Job

@DisallowConcurrentExecution
public class WatchRunner
extends Object
implements org.quartz.Job

Constructor Summary

Constructors

Constructor

Description

WatchRunner(Watch watch, org.elasticsearch.client.Client client, AccountRegistry accountRegistry, org.elasticsearch.script.ScriptService scriptService, WatchLogWriter watchLogWriter, WatchStateWriter<?> watchStateWriter, WatchState watchState, ExecutionEnvironment executionEnvironment, SimulationMode simulationMode, org.elasticsearch.common.xcontent.NamedXContentRegistry xContentRegistry, SignalsSettings signalsSettings, String nodeName, GotoCheckSelector checkSelector, NestedValueMap input)

Method Summary

Modifier and Type	Method	Description
WatchLog	execute()
void	execute(org.quartz.JobExecutionContext context)
org.elasticsearch.client.Client	getClient()
WatchExecutionContext	getCtx()
org.elasticsearch.script.ScriptService	getScriptService()
Watch	getWatch()

Methods inherited from class java.lang.Object

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

Constructor Detail

WatchRunner

public WatchRunner(Watch watch,
                   org.elasticsearch.client.Client client,
                   AccountRegistry accountRegistry,
                   org.elasticsearch.script.ScriptService scriptService,
                   WatchLogWriter watchLogWriter,
                   WatchStateWriter<?> watchStateWriter,
                   WatchState watchState,
                   ExecutionEnvironment executionEnvironment,
                   SimulationMode simulationMode,
                   org.elasticsearch.common.xcontent.NamedXContentRegistry xContentRegistry,
                   SignalsSettings signalsSettings,
                   String nodeName,
                   GotoCheckSelector checkSelector,
                   NestedValueMap input)

Method Detail

getWatch

public Watch getWatch()

getCtx

public WatchExecutionContext getCtx()

getClient

public org.elasticsearch.client.Client getClient()

getScriptService

public org.elasticsearch.script.ScriptService getScriptService()

execute

public void execute(org.quartz.JobExecutionContext context)
             throws org.quartz.JobExecutionException

Specified by:

execute in interface org.quartz.Job

Throws:

org.quartz.JobExecutionException

execute

public WatchLog execute()
                 throws WatchExecutionException

Throws:

WatchExecutionException