diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-04-03 16:05:25 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-04-03 16:05:25 +0200 |
| commit | fda35295a35e807709e1ef8b8d4dfb1e443f4d8a (patch) | |
| tree | 15d0f797ce4a92abab9e7fc286b6078c2d161024 | |
| parent | 81ed09e1d200aaf85e9c7b4ecf3544597a3446ba (diff) | |
| download | compiler-fda35295a35e807709e1ef8b8d4dfb1e443f4d8a.tar.gz compiler-fda35295a35e807709e1ef8b8d4dfb1e443f4d8a.zip | |
redesign web notification
| -rw-r--r-- | worker.js | 3 |
1 files changed, 2 insertions, 1 deletions
@@ -196,6 +196,7 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI || "amqp://localhost", await ch.ack(msgs.pop(), true); // ack all messages until the last // notify web - await Promise.all(players.map(async (p) => await ch.publish("amq.topic", p.name, new Buffer("compile_commit")) )); + await Promise.all(players.map(async (p) => await ch.publish("amq.topic", "player." + p.name, + new Buffer("stats_update")) )); } })(); |
