From 765e9356fa6b571838237cc73bc9552c1e6695d8 Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Thu, 13 Apr 2017 19:59:20 +0200
Subject: do not call analyzer

---
 worker.js | 9 ---------
 1 file changed, 9 deletions(-)

(limited to 'worker.js')

diff --git a/worker.js b/worker.js
index 1235add..05f81b6 100644
--- a/worker.js
+++ b/worker.js
@@ -41,7 +41,6 @@ function snakeCaseKeys(obj) {
             rabbit = await amqp.connect(RABBITMQ_URI, { heartbeat: 120 });
             ch = await rabbit.createChannel();
             await ch.assertQueue("process", {durable: true});
-            await ch.assertQueue("analyze", {durable: true});
             break;
         } catch (err) {
             console.error(err);
@@ -385,14 +384,6 @@ function snakeCaseKeys(obj) {
         // …global about new matches
         if (match_records.length > 0)
             await ch.publish("amq.topic", "global", new Buffer("matches_update"));
-
-        // notify analyzer
-        Promise.all(participant_stats_records.map(async (p) =>
-            await ch.sendToQueue("analyze", new Buffer(p.participant_api_id), {
-                persistent: true,
-                type: "participant"
-            })
-        ));
     }
 
     // Split participant API data into participant and participant_stats
-- 
cgit v1.3.1