diff --git a/index.js b/index.js index 9fb7670..179f198 100644 --- a/index.js +++ b/index.js @@ -6,8 +6,9 @@ var redis = require('redis'); redisClient = redis.createClient(config.globals.redis_port, config.globals.redis_host); redisClient.on("pmessage", function (pattern, channel, message) { - var gateway = channel.match(/gw:(.*)\.text/)[1]; + var gateway = channel.match(/gw:(.*)\.message$/)[1]; + console.log('----------------'); console.log(message + ' (' + gateway + ')'); }); -redisClient.psubscribe('kimochi.*.text'); +redisClient.psubscribe('echi.topup_report.*.message');