TB-MQTT发送消息遥测数据逻辑

处理设备发布消息processMqttMsg:.processPublishprocessDevicePublish

v1/devices/me/telemetry

消息处理void process(）

TbQueueProducer

MqttTransportHandler

DefaultTransportService

发送消息到本地队列或kafka等消息队列

消息读取和处理channelRead:processMqttMsg 

TransportService

发送消息和消息次数累计sendToRuleEngine