From d5f24344b7ae5d43d81cf9fecd7efee9515f1806 Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Wed, 23 Aug 2017 19:15:12 +0200
Subject: send analyze_pending

---
 worker.js | 11 ++++++++---
 1 file changed, 8 insertions(+), 3 deletions(-)

(limited to 'worker.js')

diff --git a/worker.js b/worker.js
index b95a12a..e585cc7 100644
--- a/worker.js
+++ b/worker.js
@@ -271,12 +271,17 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => {
             if (match_objects.length > 0)
                 await ch.publish("amq.topic", "global", new Buffer("matches_update"));
             // notify follow up services
-            if (DOANALYZEMATCH)  // TODO
+            if (DOANALYZEMATCH) {
                 await Promise.each(match_objects, async (msg) => {
+                    await ch.publish("amq.topic", m.properties.headers.notify,
+                        new Buffer("analyze_pending"));
                     await ch.sendToQueue(ANALYZE_QUEUE,
-                        new Buffer(msg.content.id),
-                        { persistent: true });
+                        new Buffer(msg.content.id), {
+                            persistent: true,
+                            headers: { notify: msg.properties.headers.notify }
+                        });
                 });
+            }
         } catch (err) {
             if (err instanceof Seq.TimeoutError ||
                 (err instanceof Seq.DatabaseError && err.errno == 1213)) {
-- 
cgit v1.3.1