summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2017-04-03 16:05:25 +0200
committerschneefux <schneefux+commit@schneefux.xyz>2017-04-03 16:05:25 +0200
commitfda35295a35e807709e1ef8b8d4dfb1e443f4d8a (patch)
tree15d0f797ce4a92abab9e7fc286b6078c2d161024
parent81ed09e1d200aaf85e9c7b4ecf3544597a3446ba (diff)
downloadcompiler-fda35295a35e807709e1ef8b8d4dfb1e443f4d8a.tar.gz
compiler-fda35295a35e807709e1ef8b8d4dfb1e443f4d8a.zip
redesign web notification
-rw-r--r--worker.js3
1 files changed, 2 insertions, 1 deletions
diff --git a/worker.js b/worker.js
index 066310d..652faf7 100644
--- a/worker.js
+++ b/worker.js
@@ -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")) ));
}
})();