TB-MQTT消息遥测数据消费和规则引擎处理逻辑

TbQueueConsumer

规则链流经规则节点pushMsgToNode

从消息队列中拉取消息List<T> poll(long durationInMillis)

TbNode

保存遥测数据并通知和回调saveAndNotify

遥测数据消息处理节点void onMsg(）

处理转发消息doProcess(TbActorMsg msg)

RuleChainActor

  TbMsgTimeseriesNode

转发给规则引擎Actor处理forwardToRuleEngineActor

接受并处理消息

RuleChainActorMessageProcessor

不断消费消息队列中的消息launchConsumer

RuleEngineTelemetryService

RuleNodeActorMessageProcessor 

规则链路到规则节点处理器onRuleChainToRuleNodeMsg

队列中到规则引擎过渡消息处理onQueueToRuleEngineMsg

消息处理适配器void onMsg(）

DefaultTbRuleEngineConsumerService