diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-04-03 16:04:16 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-04-03 16:04:16 +0200 |
| commit | 98ce52de77c315ae1580872d01ecbd98fba9749a (patch) | |
| tree | 9eeb9a47869a41fb2c0d0a0eb7818d3896611049 | |
| parent | 26e651c824be2f412356b02dd71538afc953bd24 (diff) | |
| download | shrinker-98ce52de77c315ae1580872d01ecbd98fba9749a.tar.gz shrinker-98ce52de77c315ae1580872d01ecbd98fba9749a.zip | |
redesign web notification
| -rw-r--r-- | worker.js | 2 |
1 files changed, 1 insertions, 1 deletions
@@ -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")); } |
