public class Correlator extends AbstractServiceDaemon implements CorrelationEngineRegistrar
Correlator class.
Modifier and Type | Field and Description |
---|---|
static String |
EVENT_PARM_PERSIST_STATE |
PAUSE_PENDING, PAUSED, RESUME_PENDING
RUNNING, START_PENDING, STARTING, STATUS_NAMES, STOP_PENDING, STOPPED
Modifier | Constructor and Description |
---|---|
protected |
Correlator()
Constructor for Correlator.
|
Modifier and Type | Method and Description |
---|---|
void |
addCorrelationEngine(CorrelationEngine engine)
addCorrelationEngine
|
void |
addCorrelationEngines(CorrelationEngine... engines)
addCorrelationEngine
|
CorrelationEngine |
findEngineByName(String name)
findEngineByName
|
Collection<CorrelationEngine> |
getEngines()
getEngines
|
protected void |
onInit()
onInit
|
protected void |
onStop()
onStop
|
void |
removeCorrelationEngine(String engineName) |
void |
setCorrelationEngines(Collection<CorrelationEngine> engines)
setCorrelationEngines
|
void |
setEventIpcManager(EventIpcManager eventIpcManager)
setEventIpcManager
|
afterPropertiesSet, destroy, getName, getStatus, getStatusText, init, isPaused, isRunning, isStarting, onPause, onResume, onStart, pause, resume, setStatus, start, status, stop, waitForStatus, waitForStatus
public static final String EVENT_PARM_PERSIST_STATE
protected void onInit()
onInit
onInit
in class AbstractServiceDaemon
protected void onStop()
onStop
onStop
in class AbstractServiceDaemon
public void setCorrelationEngines(Collection<CorrelationEngine> engines)
setCorrelationEngines
engines
- a List
object.public void setEventIpcManager(EventIpcManager eventIpcManager)
setEventIpcManager
eventIpcManager
- a EventIpcManager
object.public void addCorrelationEngine(CorrelationEngine engine)
addCorrelationEngine
addCorrelationEngine
in interface CorrelationEngineRegistrar
engine
- a CorrelationEngine
object.public void removeCorrelationEngine(String engineName)
removeCorrelationEngine
in interface CorrelationEngineRegistrar
public void addCorrelationEngines(CorrelationEngine... engines)
CorrelationEngineRegistrar
addCorrelationEngine
addCorrelationEngines
in interface CorrelationEngineRegistrar
public CorrelationEngine findEngineByName(String name)
findEngineByName
findEngineByName
in interface CorrelationEngineRegistrar
name
- a String
object.CorrelationEngine
object.public Collection<CorrelationEngine> getEngines()
getEngines
getEngines
in interface CorrelationEngineRegistrar
List
object.Copyright © 2020. All rights reserved.