Air724ugLora/demo/mqtt全双工对讲/mqttInMsg.lua

--- 模块功能：MQTT客户端数据接收处理


module(...,package.seeall)

--- MQTT客户端数据接收处理
-- @param mqttClient，MQTT客户端对象
-- @return 处理成功返回true，处理出错返回false
-- @usage mqttInMsg.proc(mqttClient)

function proc(mqttClient)
    local result,data
    while true do
        result,data = mqttClient:receive(60000,"APP_SOCKET_SEND_DATA")
        --接收到数据
        if result then
            --log.info("mqttInMsg.proc",data.topic,data.payload)
            sys.publish("audio_play_full",data.payload)--发布消息
        else
            break
        end
    end
	
    return result or data=="timeout" or data=="APP_SOCKET_SEND_DATA"
end