程序包 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	setAlarmProducer(xin.manong.weapon.alarm.AlarmProducer alarmProducer)	设置报警发送器
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,
                            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

setAlarmProducer

public void setAlarmProducer(xin.manong.weapon.alarm.AlarmProducer alarmProducer)

设置报警发送器

参数:

alarmProducer - 报警发送器

setAppName

public void setAppName(String appName)

设置应用名

参数:

appName - 应用名