org.tinygroup.channel.impl

Class AbstractChannel

java.lang.Object

org.tinygroup.channel.impl.AbstractChannel

All Implemented Interfaces:

EventProcessor, ChannelInterface

Direct Known Subclasses:

SimpleChannel

public abstract class AbstractChannel
extends Object
implements ChannelInterface

抽象通道，实现了事件相关，日志

Author:

luoguo

Field Summary

Fields inherited from interface org.tinygroup.cepcore.EventProcessor

TYPE_LOCAL, TYPE_REMOTE

Constructor Summary

Constructors

Constructor and Description
AbstractChannel()

Method Summary

Modifier and Type	Method and Description
void	addReceiveEventFilter(EventFilter eventFilter) 添加接收事件过滤器
void	addReceiveEventListener(EventListener eventListener) 添加接收事件监听器
void	addSendEventFilter(EventFilter eventFilter) 添加发送事件过滤器
void	addSendEventListener(EventListener eventListener) 添加发送事件监听器
boolean	canProcess(String nodeString) 判断当前处理器是否能处理对应的节点
CEPCore	getCepCore()
String	getId() 返回处理器ID，ID必须唯一
List<EventFilter>	getReceiveEventFilters()
List<EventListener>	getReceiveEventListeners()
List<EventFilter>	getSendEventFilters()
List<EventListener>	getSendEventListeners()
void	process(Event event) 通道去处理一个事件
protected abstract void	receive(Event event)
void	sendEvent(Event event) 发送事件
void	setCepCore(CEPCore cepCore) 设置CEPCore
void	setId(String id)
void	start() 开始通道
void	stop() 通道停止

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, getType, getWeight, isEnable, isRead, setEnable, setRead

Constructor Detail

AbstractChannel

public AbstractChannel()

Method Detail

getCepCore

public CEPCore getCepCore()

setCepCore

public void setCepCore(CEPCore cepCore)

Description copied from interface: EventProcessor

设置CEPCore

Specified by:

setCepCore in interface EventProcessor

getId

public String getId()

Description copied from interface: EventProcessor

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

Specified by:

getId in interface EventProcessor

Specified by:

getId in interface ChannelInterface

Returns:

setId

public void setId(String id)

canProcess

public boolean canProcess(String nodeString)

Description copied from interface: EventProcessor

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

Specified by:

canProcess in interface EventProcessor

Returns:

getSendEventFilters

public List<EventFilter> getSendEventFilters()

getReceiveEventFilters

public List<EventFilter> getReceiveEventFilters()

getSendEventListeners

public List<EventListener> getSendEventListeners()

getReceiveEventListeners

public List<EventListener> getReceiveEventListeners()

addSendEventListener

public void addSendEventListener(EventListener eventListener)

Description copied from interface: ChannelInterface

添加发送事件监听器

Specified by:

addSendEventListener in interface ChannelInterface

addReceiveEventListener

public void addReceiveEventListener(EventListener eventListener)

Description copied from interface: ChannelInterface

添加接收事件监听器

Specified by:

addReceiveEventListener in interface ChannelInterface

addSendEventFilter

public void addSendEventFilter(EventFilter eventFilter)

Description copied from interface: ChannelInterface

添加发送事件过滤器

Specified by:

addSendEventFilter in interface ChannelInterface

addReceiveEventFilter

public void addReceiveEventFilter(EventFilter eventFilter)

Description copied from interface: ChannelInterface

添加接收事件过滤器

Specified by:

addReceiveEventFilter in interface ChannelInterface

sendEvent

public void sendEvent(Event event)

Description copied from interface: ChannelInterface

发送事件

Specified by:

sendEvent in interface ChannelInterface

process

public void process(Event event)

通道去处理一个事件

Specified by:

process in interface EventProcessor

receive

protected abstract void receive(Event event)

start

public void start()

Description copied from interface: ChannelInterface

开始通道

Specified by:

start in interface ChannelInterface

stop

public void stop()

Description copied from interface: ChannelInterface

通道停止

Specified by:

stop in interface ChannelInterface