Modifier and Type | Method and Description |
---|---|
EventProcessor |
EventProcessorChoose.choose(List<EventProcessor> processors) |
Modifier and Type | Method and Description |
---|---|
List<EventProcessor> |
CEPCore.getEventProcessors() |
Modifier and Type | Method and Description |
---|---|
CEPCoreProcessDealer |
CEPCoreProcessFilterChain.getDealer(CEPCoreProcessDealer dealer,
Event e,
CEPCore core,
EventProcessor processor) |
void |
CEPCoreProcessFilter.process(CEPCoreProcessDealer dealer,
Event e,
CEPCore core,
EventProcessor processor) |
void |
CEPCoreProcessDealer.process(Event e,
CEPCore core,
EventProcessor processor) |
void |
CEPCore.registerEventProcessor(EventProcessor eventProcessor)
注册一个事件处理器
|
void |
EventProcessorRegisterTrigger.trigger(EventProcessor processor,
CEPCore core) |
void |
CEPCore.unregisterEventProcessor(EventProcessor eventProcessor)
注销一个事件处理器
|
Modifier and Type | Method and Description |
---|---|
EventProcessor |
EventProcessorChoose.choose(List<EventProcessor> processors) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractEventProcessor
抽象的事件处理器实现
|
Modifier and Type | Method and Description |
---|---|
EventProcessor |
WeightChooser.choose(List<EventProcessor> processors) |
Modifier and Type | Method and Description |
---|---|
CEPCoreProcessDealer |
CEPCoreProcessFilterChainImpl.getDealer(CEPCoreProcessDealer d,
Event e,
CEPCore core,
EventProcessor processor) |
Modifier and Type | Method and Description |
---|---|
EventProcessor |
WeightChooser.choose(List<EventProcessor> processors) |
Modifier and Type | Method and Description |
---|---|
static boolean |
CEPCoreUtil.isLocal(EventProcessor processor) |
Modifier and Type | Method and Description |
---|---|
void |
ContextChangeFilter.process(CEPCoreProcessDealer dealer,
Event event,
CEPCore core,
EventProcessor processor) |
void |
ExceptionDealFilter.process(CEPCoreProcessDealer dealer,
Event event,
CEPCore core,
EventProcessor processor) |
void |
ThreadVariableChangeFilter.process(CEPCoreProcessDealer dealer,
Event event,
CEPCore core,
EventProcessor processor) |
void |
CEPCoreAopFilter.process(CEPCoreProcessDealer dealer,
Event event,
CEPCore core,
EventProcessor eventProcessor) |
Modifier and Type | Method and Description |
---|---|
EventProcessor |
CEPService.getEventProcessor(String eventProcessorId) |
Modifier and Type | Method and Description |
---|---|
List<EventProcessor> |
CEPService.getEventProcessors() |
List<EventProcessor> |
CEPService.getLocalEventProcessors() |
List<EventProcessor> |
CEPService.getRemoteEventProcessors() |
Modifier and Type | Method and Description |
---|---|
List<EventProcessor> |
CEPCoreImpl.getEventProcessors() |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractCEPCoreImpl.changeVersion(EventProcessor eventProcessor) |
void |
CEPCoreDealer.process(Event event,
CEPCore core,
EventProcessor processor) |
void |
CEPCoreImpl.registerEventProcessor(EventProcessor eventProcessor) |
void |
CEPCoreImpl.unregisterEventProcessor(EventProcessor eventProcessor) |
Modifier and Type | Method and Description |
---|---|
static void |
MonitorUtil.addMonitorInfo(Event e,
CEPCore core,
EventProcessor processor)
此方法在计算出event所执行的processor后即可调用
添加from/to信息,from当前节点的nodeName,to目标处理器的id
如果是远程请求,目标处理器id为目标节点的ip:port:nodeName
如果是本地请求,目标处理器就是本地处理器id
|
static void |
MonitorUtil.addToInfo(Event e,
EventProcessor processor) |
void |
CEPCoreProcessMonitorFilter.process(CEPCoreProcessDealer dealer,
Event event,
CEPCore core,
EventProcessor processor) |
Modifier and Type | Interface and Description |
---|---|
interface |
ChannelInterface
通道接口
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractChannel
抽象通道,实现了事件相关,日志
|
Modifier and Type | Class and Description |
---|---|
class |
FlowEventProcessor |
Modifier and Type | Class and Description |
---|---|
class |
MockServiceEventProcessorImpl |
Modifier and Type | Class and Description |
---|---|
class |
ServiceHttpChannelEventProcessorImpl |
Modifier and Type | Class and Description |
---|---|
class |
ServiceEventProcessorImpl |
Modifier and Type | Class and Description |
---|---|
class |
SimpleChannel |
Copyright © 2006–2018 TinyGroup. All rights reserved.