org.tinygroup.cepcore.impl

Class AbstractEventProcessor

java.lang.Object

org.tinygroup.cepcore.impl.AbstractEventProcessor

All Implemented Interfaces:

EventProcessor

Direct Known Subclasses:

FlowEventProcessor, MockServiceEventProcessorImpl, ServiceEventProcessorImpl, ServiceHttpChannelEventProcessorImpl

public abstract class AbstractEventProcessor
extends Object
implements EventProcessor

抽象的事件处理器实现

Author:

renhui

Field Summary

Fields inherited from interface org.tinygroup.cepcore.EventProcessor

TYPE_LOCAL, TYPE_REMOTE

Constructor Summary

Constructors

Constructor and Description
AbstractEventProcessor()

Method Summary

Modifier and Type	Method and Description
boolean	canProcess(String nodeString) 判断当前处理器是否能处理对应的节点
String	getId() 返回处理器ID，ID必须唯一
int	getType() 返回处理器类型
boolean	isEnable() 获取是否是enable，如果为false，则不接收任何服务处理
void	setEnable(boolean enable) 设置enable

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.EventProcessor

getRegex, getServiceInfos, getWeight, isRead, process, setCepCore, setRead

Constructor Detail

AbstractEventProcessor

public AbstractEventProcessor()

Method Detail

canProcess

public boolean canProcess(String nodeString)

Description copied from interface: EventProcessor

判断当前处理器是否能处理对应的节点

Specified by:

canProcess in interface EventProcessor

Returns:

getId

public String getId()

Description copied from interface: EventProcessor

返回处理器ID，ID必须唯一

Specified by:

getId in interface EventProcessor

Returns:

getType

public int getType()

Description copied from interface: EventProcessor

返回处理器类型

Specified by:

getType in interface EventProcessor

Returns:

isEnable

public boolean isEnable()

Description copied from interface: EventProcessor

获取是否是enable，如果为false，则不接收任何服务处理

Specified by:

isEnable in interface EventProcessor

Returns:

setEnable

public void setEnable(boolean enable)

Description copied from interface: EventProcessor

设置enable

Specified by:

setEnable in interface EventProcessor