程序包 xin.manong.stream.boost.receiver.memory

类 MemoryReceiver

java.lang.Object

xin.manong.stream.sdk.receiver.Receiver

xin.manong.stream.boost.receiver.memory.MemoryReceiver

public class MemoryReceiver
extends xin.manong.stream.sdk.receiver.Receiver

内存数据接收器 接收流程插件处理的数据，分发下游处理 主要用于数据重新处理场景

作者:

frankcl

字段概要

字段

修饰符和类型	字段	说明
protected BlockingQueue<xin.manong.weapon.base.record.KVRecords>	recordQueue

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

alarmProducer, appName, configMap, receiveProcessor

构造器概要

构造器

构造器	说明
MemoryReceiver(Map<String,Object> configMap)

方法概要

修饰符和类型	方法	说明
boolean	start()
void	stop()

从类继承的方法 xin.manong.stream.sdk.receiver.Receiver

setAlarmProducer, setAppName

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

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

字段详细资料

recordQueue

protected BlockingQueue<xin.manong.weapon.base.record.KVRecords> recordQueue

构造器详细资料

MemoryReceiver

public MemoryReceiver(Map<String,Object> configMap)

方法详细资料

start

public boolean start()

指定者:

start 在类中 xin.manong.stream.sdk.receiver.Receiver

stop

public void stop()

指定者:

stop 在类中 xin.manong.stream.sdk.receiver.Receiver