--本例子说明使用RabbitMQ 从消息队列服务器接收数据
--本服务是一个死循环处理模式,一般需要在服务器的run_lua段中配置为
--rabbit_consume=10,2 -->2代表以服务方式单独线程运行
m_mq = CTNLuaRabbitMQ();
--设置消息服务器,setServer(ip,port,user,pass) ,后台参数可以默认不填写
m_mq:setServer('localhost');
--这个必须设置,关联内部Lua object
m_mq:setLuaID(luaid());
--回调函数,每新来一个请求都会调用此函数
function process_rabbit(sValue)
print(sValue);
end
--test2 为队列称
m_mq:consumer('test2');