org.tinygroup.cepcoreimpl

Class AbstractCEPCoreImpl

java.lang.Object

org.tinygroup.cepcoreimpl.AbstractCEPCoreImpl

All Implemented Interfaces:

CEPCore

Direct Known Subclasses:

CEPCoreImpl

public abstract class AbstractCEPCoreImpl
extends Object
implements CEPCore

Field Summary

Fields inherited from interface org.tinygroup.cepcore.CEPCore

CEP_CORE_BEAN

Constructor Summary

Constructors

Constructor and Description
AbstractCEPCoreImpl()

Method Summary

Modifier and Type	Method and Description
protected void	changeVersion(EventProcessor eventProcessor)
CEPCoreAopManager	getAopMananger()
protected EventProcessorChoose	getEventProcessorChoose()
protected ExecutorService	getExecutorService()
String	getNodeName() 获取结点名称
CEPCoreOperator	getOperator()
int	getServiceInfosVersion()
protected void	initThreadPool(String configBean)
void	setAopMananger(CEPCoreAopManager aopMananger)
void	setConfig(XmlNode config)
void	setEventProcessorChoose(EventProcessorChoose eventProcessorChoose)
void	setNodeName(String nodeName)
void	setOperator(CEPCoreOperator operator)
void	start() 开始CEP
void	startCEPCore(CEPCore cep)
void	stop() 停止CEP
void	stopCEPCore(CEPCore cep)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.tinygroup.cepcore.CEPCore

addEventProcessorRegisterTrigger, getEventProcessors, getServiceInfo, getServiceInfos, process, refreshEventProcessors, registerEventProcessor, unregisterEventProcessor

Constructor Detail

AbstractCEPCoreImpl

public AbstractCEPCoreImpl()

Method Detail

getAopMananger

public CEPCoreAopManager getAopMananger()

setAopMananger

public void setAopMananger(CEPCoreAopManager aopMananger)

getNodeName

public String getNodeName()

Description copied from interface: CEPCore

获取结点名称

Specified by:

getNodeName in interface CEPCore

Returns:

setNodeName

public void setNodeName(String nodeName)

Specified by:

setNodeName in interface CEPCore

getOperator

public CEPCoreOperator getOperator()

Specified by:

getOperator in interface CEPCore

setOperator

public void setOperator(CEPCoreOperator operator)

Specified by:

setOperator in interface CEPCore

startCEPCore

public void startCEPCore(CEPCore cep)

stopCEPCore

public void stopCEPCore(CEPCore cep)

start

public void start()

Description copied from interface: CEPCore

开始CEP

Specified by:

start in interface CEPCore

stop

public void stop()

Description copied from interface: CEPCore

停止CEP

Specified by:

stop in interface CEPCore

setConfig

public void setConfig(XmlNode config)

Specified by:

setConfig in interface CEPCore

initThreadPool

protected void initThreadPool(String configBean)

getExecutorService

protected ExecutorService getExecutorService()

changeVersion

protected void changeVersion(EventProcessor eventProcessor)

getServiceInfosVersion

public int getServiceInfosVersion()

Specified by:

getServiceInfosVersion in interface CEPCore

getEventProcessorChoose

protected EventProcessorChoose getEventProcessorChoose()

setEventProcessorChoose

public void setEventProcessorChoose(EventProcessorChoose eventProcessorChoose)

Specified by:

setEventProcessorChoose in interface CEPCore