xin.manong.stream.framework.receiver

类 ReceiveProcessorImpl

java.lang.Object

xin.manong.stream.sdk.receiver.ReceiveProcessor

xin.manong.stream.framework.receiver.ReceiveProcessorImpl

public class ReceiveProcessorImpl
extends ReceiveProcessor

接收数据处理器实现 处理接收数据，根据配置分发到对应processor进行处理

作者:

frankcl

字段概要

从类继承的字段 xin.manong.stream.sdk.receiver.ReceiveProcessor

converter

构造器概要

构造器

构造器和说明
ReceiveProcessorImpl(String name, List<String> processors, List<ProcessorConfig> processorGraphConfig, ReceiveConverter converter)

方法概要

限定符和类型	方法和说明
void	process(Object object)
void	setAlarmSender(xin.manong.weapon.alarm.AlarmSender alarmSender) 设置报警发送器
void	setAppName(String appName) 设置应用名
void	sweep()

从类继承的方法 java.lang.Object

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

构造器详细资料

ReceiveProcessorImpl

public ReceiveProcessorImpl(String name,
                            List<String> processors,
                            List<ProcessorConfig> processorGraphConfig,
                            ReceiveConverter converter)

方法详细资料

process

public void process(Object object)
             throws Throwable

指定者:

process 在类中 ReceiveProcessor

抛出:

Throwable

sweep

public void sweep()

指定者:

sweep 在类中 ReceiveProcessor

setAlarmSender

public void setAlarmSender(xin.manong.weapon.alarm.AlarmSender alarmSender)

设置报警发送器

参数:

alarmSender - 报警发送器

setAppName

public void setAppName(String appName)

设置应用名

参数:

appName - 应用名