org.tinygroup.cepcore

Interface EventProcessor

All Known Subinterfaces:

ChannelInterface

All Known Implementing Classes:

AbstractChannel, AbstractEventProcessor, FlowEventProcessor, MockServiceEventProcessorImpl, ServiceEventProcessorImpl, ServiceHttpChannelEventProcessorImpl, SimpleChannel

public interface EventProcessor

事件处理器 ，每个事件处理器，都需要提供其ID，路由表及处理器

Author:

luoguo

Field Summary

Fields

Modifier and Type	Field and Description
static int	TYPE_LOCAL
static int	TYPE_REMOTE

Method Summary

Modifier and Type	Method and Description
boolean	canProcess(String nodeString) 判断当前处理器是否能处理对应的节点
String	getId() 返回处理器ID，ID必须唯一
List<String>	getRegex() 返回正则
List<ServiceInfo>	getServiceInfos() 返回当前处理器中的所有服务
int	getType() 返回处理器类型
int	getWeight() 返回处理权重
boolean	isEnable() 获取是否是enable，如果为false，则不接收任何服务处理
boolean	isRead() 获取是否已被读取状态
void	process(Event event) 处理事件
void	setCepCore(CEPCore cepCore) 设置CEPCore
void	setEnable(boolean enable) 设置enable
void	setRead(boolean read) 设置读取状态，当刷新时，将此状态设置为false,当注册完成后，设置为true

Field Detail

TYPE_REMOTE

static final int TYPE_REMOTE

See Also:

Constant Field Values

TYPE_LOCAL

static final int TYPE_LOCAL

See Also:

Constant Field Values

Method Detail

canProcess

boolean canProcess(String nodeString)

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

Parameters:

nodeString -

Returns:

process

void process(Event event)

处理事件

Parameters:

event -

setCepCore

void setCepCore(CEPCore cepCore)

设置CEPCore

Parameters:

cepCore -

getServiceInfos

List<ServiceInfo> getServiceInfos()

返回当前处理器中的所有服务

Returns:

getId

String getId()

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

Returns:

getType

int getType()

返回处理器类型

Returns:

getWeight

int getWeight()

返回处理权重

Returns:

getRegex

List<String> getRegex()

返回正则

Returns:

isRead

boolean isRead()

获取是否已被读取状态

Returns:

setRead

void setRead(boolean read)

设置读取状态，当刷新时，将此状态设置为false,当注册完成后，设置为true

Parameters:

read -

isEnable

boolean isEnable()

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

Returns:

setEnable

void setEnable(boolean enable)

设置enable

Parameters:

enable -