diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-12-23 14:56:42 +0100 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-12-23 14:56:42 +0100 |
| commit | 4dd360a9c7904a93f9e4f256f8dca8b960538b0b (patch) | |
| tree | 4da7d2023838c58a9c027d1775d57dfd09a7cca1 | |
| parent | 5cf876b99ecf85a6a5e5ab4bb3ce0b03e8f1ccb4 (diff) | |
| download | processor-4dd360a9c7904a93f9e4f256f8dca8b960538b0b.tar.gz processor-4dd360a9c7904a93f9e4f256f8dca8b960538b0b.zip | |
forward all game modes to analyzer
| -rw-r--r-- | worker.js | 16 |
1 files changed, 7 insertions, 9 deletions
@@ -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) { |
