--1 objMq:publish()--塞入数据
    objMq:publish(1,'da_num');

    --2 objMq:consumer() --定义消息，循环
    objMq:consumer('da_num') --当有数据过来时，函数内部自动调用本脚本的 process_rabbit() 

    --3 objMq:stopConsumer() --停止订阅
    objMq:stopConsumer() 

    --4 objMq:consumerTimeout() --周期订阅,秒
    objMq:consumerTimeout('da_num',30) 

    --5 objMq:getConsume() --周期订阅,秒
    local sValue=objMq:getConsume('da_num') 
    print(sValue)