org.tinygroup.cepcoreimpl

Class CEPCoreImpl

java.lang.Object

org.tinygroup.cepcoreimpl.AbstractCEPCoreImpl

org.tinygroup.cepcoreimpl.CEPCoreImpl

All Implemented Interfaces:

CEPCore

public class CEPCoreImpl
extends AbstractCEPCoreImpl

当服务执行远程调用时 如果有多个远程处理器可用，则根据配置的EventProcessorChoose choose进行调用 如果未曾配置，则默认为chooser生成权重chooser进行处理

Author:

chenjiao

Field Summary

Fields inherited from interface org.tinygroup.cepcore.CEPCore

CEP_CORE_BEAN

Constructor Summary

Constructors

Constructor and Description
CEPCoreImpl()

Method Summary

Modifier and Type	Method and Description
void	addEventProcessorRegisterTrigger(EventProcessorRegisterTrigger trigger)
CEPCoreProcessFilterChain	getChain()
CEPCoreProcessDealer	getDealer()
List<EventProcessor>	getEventProcessors()
ServiceInfo	getServiceInfo(String serviceId)
List<ServiceInfo>	getServiceInfos() 获取本地服务列表
void	process(Event event) 处理事件
void	refreshEventProcessors()
void	registerEventProcessor(EventProcessor eventProcessor) 注册一个事件处理器
void	setChain(CEPCoreProcessFilterChain chain)
void	setDealer(CEPCoreProcessDealer dealer)
void	unregisterEventProcessor(EventProcessor eventProcessor) 注销一个事件处理器

Methods inherited from class org.tinygroup.cepcoreimpl.AbstractCEPCoreImpl

changeVersion, getAopMananger, getEventProcessorChoose, getExecutorService, getNodeName, getOperator, getServiceInfosVersion, initThreadPool, setAopMananger, setConfig, setEventProcessorChoose, setNodeName, setOperator, start, startCEPCore, stop, stopCEPCore

Methods inherited from class java.lang.Object

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

Constructor Detail

CEPCoreImpl

public CEPCoreImpl()

Method Detail

registerEventProcessor

public void registerEventProcessor(EventProcessor eventProcessor)

Description copied from interface: CEPCore

注册一个事件处理器

unregisterEventProcessor

public void unregisterEventProcessor(EventProcessor eventProcessor)

Description copied from interface: CEPCore

注销一个事件处理器

process

public void process(Event event)

Description copied from interface: CEPCore

处理事件

getServiceInfos

public List<ServiceInfo> getServiceInfos()

Description copied from interface: CEPCore

获取本地服务列表

Returns:

getServiceInfo

public ServiceInfo getServiceInfo(String serviceId)

addEventProcessorRegisterTrigger

public void addEventProcessorRegisterTrigger(EventProcessorRegisterTrigger trigger)

refreshEventProcessors

public void refreshEventProcessors()

getEventProcessors

public List<EventProcessor> getEventProcessors()

getChain

public CEPCoreProcessFilterChain getChain()

setChain

public void setChain(CEPCoreProcessFilterChain chain)

getDealer

public CEPCoreProcessDealer getDealer()

setDealer

public void setDealer(CEPCoreProcessDealer dealer)