summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2017-04-03 16:04:16 +0200
committerschneefux <schneefux+commit@schneefux.xyz>2017-04-03 16:04:16 +0200
commit98ce52de77c315ae1580872d01ecbd98fba9749a (patch)
tree9eeb9a47869a41fb2c0d0a0eb7818d3896611049
parent26e651c824be2f412356b02dd71538afc953bd24 (diff)
downloadshrinker-98ce52de77c315ae1580872d01ecbd98fba9749a.tar.gz
shrinker-98ce52de77c315ae1580872d01ecbd98fba9749a.zip
redesign web notification
-rw-r--r--worker.js2
1 files changed, 1 insertions, 1 deletions
diff --git a/worker.js b/worker.js
index 65befbc..a943d8c 100644
--- a/worker.js
+++ b/worker.js
@@ -260,7 +260,7 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI || "amqp://localhost",
// notify web
await Promise.all(player_records.map(async (p) =>
- await ch.publish("amq.topic", p.name, new Buffer("process_commit")) ));
+ await ch.publish("amq.topic", "player." + p.name, new Buffer("matches_update")) ));
if (match_records.length > 0)
await ch.publish("amq.topic", "global", new Buffer("matches_update"));
}