org.tinygroup.flowprocessor

Class FlowEventProcessor

java.lang.Object

org.tinygroup.cepcore.impl.AbstractEventProcessor

org.tinygroup.flowprocessor.FlowEventProcessor

All Implemented Interfaces:

EventProcessor

public class FlowEventProcessor
extends AbstractEventProcessor

Field Summary

Fields inherited from interface org.tinygroup.cepcore.EventProcessor

TYPE_LOCAL, TYPE_REMOTE

Constructor Summary

Constructors

Constructor and Description
FlowEventProcessor()

Method Summary

Modifier and Type	Method and Description
List<String>	getRegex() 返回正则
List<ServiceInfo>	getServiceInfos() 返回当前处理器中的所有服务
int	getWeight() 返回处理权重
boolean	isRead() 获取是否已被读取状态
void	process(Event event) 处理事件
void	setCepCore(CEPCore cepCore) 设置CEPCore
void	setExecutor(FlowExecutor executor)
void	setRead(boolean read) 设置读取状态，当刷新时，将此状态设置为false,当注册完成后，设置为true

Methods inherited from class org.tinygroup.cepcore.impl.AbstractEventProcessor

canProcess, getId, getType, isEnable, setEnable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlowEventProcessor

public FlowEventProcessor()

Method Detail

process

public void process(Event event)

Description copied from interface: EventProcessor

处理事件

setCepCore

public void setCepCore(CEPCore cepCore)

Description copied from interface: EventProcessor

设置CEPCore

setExecutor

public void setExecutor(FlowExecutor executor)

getServiceInfos

public List<ServiceInfo> getServiceInfos()

Description copied from interface: EventProcessor

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

Returns:

getWeight

public int getWeight()

Description copied from interface: EventProcessor

返回处理权重

Returns:

getRegex

public List<String> getRegex()

Description copied from interface: EventProcessor

返回正则

Returns:

isRead

public boolean isRead()

Description copied from interface: EventProcessor

获取是否已被读取状态

Returns:

setRead

public void setRead(boolean read)

Description copied from interface: EventProcessor

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