Modifier and Type | Method and Description |
---|---|
Event |
CEPCoreRemoteInterface.remoteprocess(Event event,
Node remoteNode) |
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 |
CEPCore.process(Event event)
处理事件
|
void |
EventProcessor.process(Event event)
处理事件
|
void |
CEPCoreProcessDealer.process(Event e,
CEPCore core,
EventProcessor processor) |
Event |
CEPCoreRemoteInterface.remoteprocess(Event event,
Node remoteNode) |
Modifier and Type | Method and Description |
---|---|
void |
CEPCoreAopManager.afterHandle(Event event) |
void |
CEPCoreAopManager.afterLocalHandle(Event event) |
void |
CEPCoreAopManager.afterRemoteHandle(Event event) |
void |
CEPCoreAopManager.beforeHandle(Event event) |
void |
CEPCoreAopManager.beforeLocalHandle(Event event) |
void |
CEPCoreAopManager.beforeRemoteHandle(Event event) |
void |
CEPCoreAopAdapter.handle(Event event) |
boolean |
CEPCoreAopProcessor.isMatch(Event event)
是否匹配
|
void |
CEPCoreAopProcessor.process(Event event)
匹配时处理事件
|
Modifier and Type | Method and Description |
---|---|
void |
CEPCoreAopManagerImpl.afterHandle(Event event) |
void |
CEPCoreAopManagerImpl.afterLocalHandle(Event event) |
void |
CEPCoreAopManagerImpl.afterRemoteHandle(Event event) |
void |
CEPCoreAopManagerImpl.beforeHandle(Event event) |
void |
CEPCoreAopManagerImpl.beforeLocalHandle(Event event) |
void |
CEPCoreAopManagerImpl.beforeRemoteHandle(Event event) |
void |
RequestParamValidate.handle(Event event) |
void |
CEPCoreAopAdapterContainer.handle(Event e) |
Modifier and Type | Method and Description |
---|---|
CEPCoreProcessDealer |
CEPCoreProcessFilterChainImpl.getDealer(CEPCoreProcessDealer d,
Event e,
CEPCore core,
EventProcessor processor) |
Modifier and Type | Method and Description |
---|---|
static Context |
CEPCoreUtil.getContext(Event event,
ServiceInfo info,
ClassLoader loder) |
static boolean |
CEPCoreUtil.handle(Throwable e,
Event event,
ClassLoader loader) |
static boolean |
CEPCoreUtil.isTinySysService(Event event) |
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 |
---|---|
protected static void |
SpecialServiceExecuteContainer.addExecuteException(Event e,
Exception t) |
protected static void |
CommonServiceExecuteContainer.addExecuteException(Event e,
Exception t) |
protected static void |
SpecialServiceExecuteContainer.addLocalExecuteAfter(Event e) |
protected static void |
CommonServiceExecuteContainer.addLocalExecuteAfter(Event e) |
protected static void |
SpecialServiceExecuteContainer.addLocalExecuteBefore(Event e) |
protected static void |
CommonServiceExecuteContainer.addLocalExecuteBefore(Event e) |
protected static void |
SpecialServiceExecuteContainer.addRemoteExecuteAfter(Event e) |
protected static void |
CommonServiceExecuteContainer.addRemoteExecuteAfter(Event e) |
protected static void |
SpecialServiceExecuteContainer.addRemoteExecuteBefore(Event e) |
protected static void |
CommonServiceExecuteContainer.addRemoteExecuteBefore(Event e) |
void |
ServiceAfterRemoteExecuteCounter.handle(Event event) |
void |
ServiceBeforeLocalExecuteCounter.handle(Event event) |
void |
ServiceAfterLocalExecuteCounter.handle(Event event) |
void |
ServiceBeforeRemoteExecuteCounter.handle(Event event) |
void |
ServiceExceptionHanlder.handle(Exception t,
Event event) |
Modifier and Type | Method and Description |
---|---|
void |
SpecialExecuteInfoContainer.addExecuteAfter(Event e) |
void |
CommonExecuteInfoContainer.addExecuteAfter(Event e) |
void |
SpecialExecuteInfoContainer.addExecuteBefore(Event e) |
void |
CommonExecuteInfoContainer.addExecuteBefore(Event e) |
void |
SpecialExecuteInfoContainer.addExecuteException(Event e,
Exception t) |
void |
CommonExecuteInfoContainer.addExecuteException(Event e,
Exception t) |
Modifier and Type | Method and Description |
---|---|
static void |
ServiceParamUtil.changeEventContext(Event event,
CEPCore core,
ClassLoader loader) |
void |
CEPCoreImpl.process(Event event) |
void |
CEPCoreDealer.process(Event event,
CEPCore core,
EventProcessor processor) |
static void |
ServiceParamUtil.resetEventContext(Event event,
CEPCore core,
Context oldContext) |
Modifier and Type | Method and Description |
---|---|
static void |
LocalThreadContextUtil.synAfterCall(Event event)
异步服务调用的主线程发起之后
|
static void |
LocalThreadContextUtil.synBeforeCall(Event event)
异步服务调用的主线程发起之前
|
static void |
LocalThreadContextUtil.synBeforeProcess(Event event)
异步服务执行线程执行之前
|
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
|
static void |
MonitorUtil.addToInfo(Event e,
EventProcessor processor) |
void |
CEPCoreProcessMonitorFilter.process(CEPCoreProcessDealer dealer,
Event event,
CEPCore core,
EventProcessor processor) |
Modifier and Type | Method and Description |
---|---|
Event |
EventFilter.filter(Event event)
事件过滤后,会返回事件,返回的事件可以与传入的事件不同
|
Modifier and Type | Method and Description |
---|---|
Event |
EventFilter.filter(Event event)
事件过滤后,会返回事件,返回的事件可以与传入的事件不同
|
void |
EventListener.process(Event event)
处理事件
|
void |
ChannelInterface.sendEvent(Event event)
发送事件
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractChannel.process(Event event)
通道去处理一个事件
|
protected abstract void |
AbstractChannel.receive(Event event) |
void |
AbstractChannel.sendEvent(Event event) |
Modifier and Type | Method and Description |
---|---|
static Event |
Event.copy(Event event) |
static Event |
Event.createEvent(String serviceId,
Context context) |
static Event |
Event.createEvent(String serviceId,
String nodeName,
Context context) |
Modifier and Type | Method and Description |
---|---|
static Event |
Event.copy(Event event) |
Modifier and Type | Method and Description |
---|---|
void |
ExceptionHandler.handle(T t,
Event event) |
boolean |
ExceptionHandlerManager.handle(Throwable t,
Event event) |
boolean |
ExceptionHandlerManager.handleWithAllHandler(Throwable t,
Event event) |
Modifier and Type | Method and Description |
---|---|
boolean |
ExceptionHandlerManagerImpl.handle(Throwable e,
Event event) |
boolean |
ExceptionHandlerManagerImpl.handleWithAllHandler(Throwable e,
Event event) |
Modifier and Type | Method and Description |
---|---|
void |
FlowEventProcessor.process(Event event) |
Modifier and Type | Method and Description |
---|---|
void |
MockServiceEventProcessorImpl.process(Event event) |
Modifier and Type | Method and Description |
---|---|
void |
ServiceRunExceptionHandler.handle(ServiceRunException e,
Event event) |
Modifier and Type | Method and Description |
---|---|
void |
ServiceHttpChannelEventProcessorImpl.process(Event event) |
Modifier and Type | Method and Description |
---|---|
void |
ServiceEventProcessorImpl.process(Event event) |
Modifier and Type | Method and Description |
---|---|
protected void |
SimpleChannel.receive(Event event) |
Copyright © 2006–2018 TinyGroup. All rights reserved.