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 Receiver

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

作者:

frankcl

字段概要

字段

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

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

alarmSender, appName, configMap, receiveProcessor

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
boolean	start()
void	stop()

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

setAlarmSender, 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 在类中 Receiver

stop

public void stop()

指定者:

stop 在类中 Receiver