程序包 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 xin.manong.stream.sdk.receiver.ReceiveProcessor

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

作者:

frankcl

字段概要

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

converter

构造器概要

构造器

构造器	说明
ReceiveProcessorImpl(String name, List<String> processors, List<ProcessorConfig> processorGraphConfig, xin.manong.stream.sdk.receiver.ReceiveConverter converter)

方法概要

修饰符和类型	方法	说明
void	process(Object object)
void	setAlarmSender(xin.manong.weapon.alarm.AlarmSender alarmSender)	设置报警发送器
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,
                            xin.manong.stream.sdk.receiver.ReceiveConverter converter)

方法详细资料

process

public void process(Object object)
             throws Throwable

指定者:

process 在类中 xin.manong.stream.sdk.receiver.ReceiveProcessor

抛出:

Throwable

sweep

public void sweep()

指定者:

sweep 在类中 xin.manong.stream.sdk.receiver.ReceiveProcessor

setAlarmSender

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

设置报警发送器

参数:

alarmSender - 报警发送器