do not forward to cruncher, data depends on analyzer

1 files changed, 0 insertions, 7 deletions

diff --git a/worker.js b/worker.js
index 16f7708..37cc25a 100644
--- a/worker.js
+++ b/worker.js
@@ -26,8 +26,6 @@ const RABBITMQ_URI = process.env.RABBITMQ_URI,
     MAXCONNS = parseInt(process.env.MAXCONNS) || 10,  // how many concurrent actions
     DOANALYZEMATCH = process.env.DOANALYZEMATCH == "true",
     ANALYZE_QUEUE = process.env.ANALYZE_QUEUE || "analyze",
-    DOCRUNCHMATCH = process.env.DOCRUNCHMATCH == "true",
-    CRUNCH_PLAYER_QUEUE = process.env.CRUNCH_PLAYER_QUEUE || "crunch_player",
     LOAD_TIMEOUT = parseFloat(process.env.LOAD_TIMEOUT) || 5000, // ms
     IDLE_TIMEOUT = parseFloat(process.env.IDLE_TIMEOUT) || 700;  // ms
 
@@ -277,11 +275,6 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => {
                 await Promise.each(match_objects, async (m) =>
                     await ch.sendToQueue(ANALYZE_QUEUE, new Buffer(m.id),
                         { persistent: true }));
-            if (DOCRUNCHMATCH) {
-                await Promise.each(match_objects, async (m) =>
-                    await ch.sendToQueue(CRUNCH_PLAYER_QUEUE, new Buffer(m.id),
-                        { persistent: true }));
-            }
         } catch (err) {
             if (err instanceof Seq.TimeoutError) {
                 // deadlocks / timeout