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 |
EventProcessor.setCepCore(CEPCore cepCore)
设置CEPCore
|
void |
CEPCoreOperator.setCEPCore(CEPCore cep)
设置CEPCore
|
void |
CEPCoreOperator.startCEPCore(CEPCore cep)
启动节点
|
void |
CEPCoreRemoteInterface.startCEPCore(CEPCore cep,
Node node) |
void |
CEPCoreOperator.stopCEPCore(CEPCore cep)
停止节点
|
void |
CEPCoreRemoteInterface.stopCEPCore(CEPCore cep,
Node node) |
void |
EventProcessorRegisterTrigger.trigger(EventProcessor processor,
CEPCore core) |
Modifier and Type | Method and Description |
---|---|
CEPCore |
RequestParamValidate.getCepCore() |
Modifier and Type | Method and Description |
---|---|
void |
RequestParamValidate.setCepCore(CEPCore cepCore) |
Modifier and Type | Method and Description |
---|---|
CEPCoreProcessDealer |
CEPCoreProcessFilterChainImpl.getDealer(CEPCoreProcessDealer d,
Event e,
CEPCore core,
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 |
---|---|
CEPCore |
CEPService.getCore() |
Modifier and Type | Method and Description |
---|---|
void |
CEPService.setCore(CEPCore core) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractCEPCoreImpl |
class |
CEPCoreImpl
当服务执行远程调用时 如果有多个远程处理器可用,则根据配置的EventProcessorChoose choose进行调用
如果未曾配置,则默认为chooser生成权重chooser进行处理
|
Modifier and Type | Method and Description |
---|---|
CEPCore |
EventProcessorChangeListener.getCepcore() |
CEPCore |
CepCoreProcessor.getCepcore() |
Modifier and Type | Method and Description |
---|---|
static void |
ServiceParamUtil.changeEventContext(Event event,
CEPCore core,
ClassLoader loader) |
void |
CEPCoreDealer.process(Event event,
CEPCore core,
EventProcessor processor) |
static void |
ServiceParamUtil.resetEventContext(Event event,
CEPCore core,
Context oldContext) |
void |
EventProcessorChangeListener.setCepcore(CEPCore cepcore) |
void |
CepCoreProcessor.setCepcore(CEPCore cepcore) |
void |
AbstractCEPCoreImpl.startCEPCore(CEPCore cep) |
void |
AbstractCEPCoreImpl.stopCEPCore(CEPCore cep) |
Modifier and Type | Method and Description |
---|---|
static void |
MonitorUtil.addFormInfo(Event e,
CEPCore core) |
static void |
MonitorUtil.addMonitorInfo(Event e,
CEPCore core,
EventProcessor processor)
此方法在计算出event所执行的processor后即可调用
添加from/to信息,from当前节点的nodeName,to目标处理器的id
如果是远程请求,目标处理器id为目标节点的ip:port:nodeName
如果是本地请求,目标处理器就是本地处理器id
|
void |
CEPCoreProcessMonitorFilter.process(CEPCoreProcessDealer dealer,
Event event,
CEPCore core,
EventProcessor processor) |
Modifier and Type | Method and Description |
---|---|
CEPCore |
AbstractChannel.getCepCore() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractChannel.setCepCore(CEPCore cepCore) |
Modifier and Type | Method and Description |
---|---|
CEPCore |
FlowApplicationProcessor.getCepcore() |
Modifier and Type | Method and Description |
---|---|
void |
FlowApplicationProcessor.setCepcore(CEPCore cepcore) |
void |
FlowEventProcessor.setCepCore(CEPCore cepCore) |
Modifier and Type | Method and Description |
---|---|
CEPCore |
CallServiceComponent.getCepCore() |
CEPCore |
CallFlow.getCepCore() |
Modifier and Type | Method and Description |
---|---|
void |
CallServiceComponent.setCepCore(CEPCore cepCore) |
void |
CallFlow.setCepCore(CEPCore cepCore) |
Modifier and Type | Method and Description |
---|---|
CEPCore |
MockServiceApplicationProcessorImpl.getCepcore() |
Modifier and Type | Method and Description |
---|---|
void |
MockServiceApplicationProcessorImpl.setCepcore(CEPCore cepcore) |
void |
MockServiceEventProcessorImpl.setCepCore(CEPCore cepCore) |
Modifier and Type | Method and Description |
---|---|
CEPCore |
MockServiceProcessor.getCore() |
Modifier and Type | Method and Description |
---|---|
void |
MockServiceProcessor.setCore(CEPCore core) |
Modifier and Type | Method and Description |
---|---|
CEPCore |
ServiceHttpChannelApplicationProcessorImpl.getCepcore() |
Modifier and Type | Method and Description |
---|---|
void |
ServiceHttpChannelApplicationProcessorImpl.setCepcore(CEPCore cepcore) |
void |
ServiceHttpChannelEventProcessorImpl.setCepCore(CEPCore cepCore) |
Modifier and Type | Method and Description |
---|---|
CEPCore |
ServiceHttpServiceProcessor.getCore() |
Modifier and Type | Method and Description |
---|---|
void |
ServiceHttpServiceProcessor.setCore(CEPCore core) |
Modifier and Type | Method and Description |
---|---|
CEPCore |
ServiceApplicationProcessor.getCepcore() |
Modifier and Type | Method and Description |
---|---|
void |
ServiceApplicationProcessor.setCepcore(CEPCore cepcore) |
void |
ServiceEventProcessorImpl.setCepCore(CEPCore cepCore) |
Modifier and Type | Method and Description |
---|---|
CEPCore |
ServiceTinyProcessor.getCore() |
CEPCore |
JsonServiceTinyProcessor.getCore() |
CEPCore |
JsonServiceHeadConfigTinyProcessor.getCore() |
CEPCore |
ServiceOutPutTinyProcessor.getCore() |
Modifier and Type | Method and Description |
---|---|
void |
ServiceTinyProcessor.setCore(CEPCore core) |
void |
JsonServiceTinyProcessor.setCore(CEPCore core) |
void |
JsonServiceHeadConfigTinyProcessor.setCore(CEPCore core) |
void |
ServiceOutPutTinyProcessor.setCore(CEPCore core) |
Modifier and Type | Method and Description |
---|---|
CEPCore |
ServiceWrapperInterceptor.getCore() |
Modifier and Type | Method and Description |
---|---|
void |
ServiceWrapperInterceptor.setCore(CEPCore core) |
Modifier and Type | Method and Description |
---|---|
CEPCore |
ServiceParameterNameDiscoverer.getCore() |
Modifier and Type | Method and Description |
---|---|
void |
ServiceParameterNameDiscoverer.setCore(CEPCore core) |
Modifier and Type | Method and Description |
---|---|
CEPCore |
TG_WSServletContextListener.getCore() |
Modifier and Type | Method and Description |
---|---|
void |
TG_WSServletContextListener.setCore(CEPCore core) |
Copyright © 2006–2018 TinyGroup. All rights reserved.