fix

Adhidarma Hadiwinoto
1 parent c9c4e56660
Showing 1 changed file with 3 additions and 2 deletions Side-by-side Diff
index.js
@@ -6,8 +6,9 @@ var redis = require(&#39;redis&#39;);
 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');
...	...	@@ -6,8 +6,9 @@ var redis = require('redis');
6	6	redisClient = redis.createClient(config.globals.redis_port, config.globals.redis_host);
7	7
8	8	redisClient.on("pmessage", function (pattern, channel, message) {
9		- var gateway = channel.match(/gw:(.*)\.text/)[1];
	9	+ var gateway = channel.match(/gw:(.*)\.message$/)[1];
	10	+ console.log('----------------');
10	11	console.log(message + ' (' + gateway + ')');
11	12	});
12	13
13		-redisClient.psubscribe('kimochi.*.text');
	14	+redisClient.psubscribe('echi.topup_report.*.message');