summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2017-12-23 14:56:42 +0100
committerschneefux <schneefux+commit@schneefux.xyz>2017-12-23 14:56:42 +0100
commit4dd360a9c7904a93f9e4f256f8dca8b960538b0b (patch)
tree4da7d2023838c58a9c027d1775d57dfd09a7cca1
parent5cf876b99ecf85a6a5e5ab4bb3ce0b03e8f1ccb4 (diff)
downloadprocessor-4dd360a9c7904a93f9e4f256f8dca8b960538b0b.tar.gz
processor-4dd360a9c7904a93f9e4f256f8dca8b960538b0b.zip
forward all game modes to analyzer
-rw-r--r--worker.js16
1 files changed, 7 insertions, 9 deletions
diff --git a/worker.js b/worker.js
index 33dba6a..ed0bf10 100644
--- a/worker.js
+++ b/worker.js
@@ -290,15 +290,13 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => {
// notify follow up services
if (DOANALYZEMATCH) {
await Promise.each(match_objects, async (msg) => {
- if (["casual", "ranked"].includes(msg.content.game_mode)) {
- await ch.publish("amq.topic", msg.properties.headers.notify,
- new Buffer("analyze_pending"));
- await ch.sendToQueue(ANALYZE_QUEUE,
- new Buffer(msg.content.id), {
- persistent: true,
- headers: { notify: msg.properties.headers.notify }
- });
- }
+ await ch.publish("amq.topic", msg.properties.headers.notify,
+ new Buffer("analyze_pending"));
+ await ch.sendToQueue(ANALYZE_QUEUE,
+ new Buffer(msg.content.id), {
+ persistent: true,
+ headers: { notify: msg.properties.headers.notify }
+ });
});
}
} catch (err) {