public class Correlator extends AbstractServiceDaemon implements CorrelationEngineRegistrar
Correlator class.
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
|
List<CorrelationEngine> |
getEngines()
getEngines
|
protected void |
onInit()
onInit
|
void |
setCorrelationEngines(List<CorrelationEngine> engines)
setCorrelationEngines
|
void |
setEventIpcManager(EventIpcManager eventIpcManager)
setEventIpcManager
|
afterPropertiesSet, destroy, getName, getStatus, getStatusText, init, isPaused, isRunning, isStarting, onPause, onResume, onStart, onStop, pause, resume, setStatus, start, status, stop, waitForStatus, waitForStatus
protected void onInit()
onInit
onInit
in class AbstractServiceDaemon
public void setCorrelationEngines(List<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 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 List<CorrelationEngine> getEngines()
getEngines
getEngines
in interface CorrelationEngineRegistrar
List
object.Copyright © 2016. All rights reserved.