From 76d34a2df37ec24150cd020984ac7e2ae5e85873 Mon Sep 17 00:00:00 2001 From: schneefux Date: Wed, 14 Jun 2017 13:13:06 +0200 Subject: send notifications for everything --- worker.js | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/worker.js b/worker.js index 3ce65ca..308bcc7 100644 --- a/worker.js +++ b/worker.js @@ -810,8 +810,9 @@ function flatten(obj) { ); } - await ch.publish("amq.topic", m.properties.headers.notify, - new Buffer(notif)); + if (m.properties.headers.donotify == true) // TODO remove later + await ch.publish("amq.topic", m.properties.headers.notify, + new Buffer(notif)); }); // …global about new matches if (match_records.length > 0) -- cgit v1.3.1