send notifications for everything

1 files 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)