var redis   = require('redis');
var config=require('./config.js')
var client  = redis.createClient(config.redis.port, config.redis.host,{
	db:config.redis.db,password:config.redis.auth
});


//在ready回调内订阅message_pub 
client.on('ready',function(){
	client.select('1',function(err){
		if(!err){
			//订阅消息	
			client.subscribe('rmcc',function(type){
				console.log('rmcc success ')
			});
		}else{
			console.error(err);
		}
	})
	
})
//订阅消息事件
exports.init_sub=function(call){	
	client.on("message", function (channel, message) {
	    console.log("channel="+channel+";message=" + message);
	    call(channel,message)
	});		
}