From f17be0931634b7b37632e703a9845e3a28cbb698 Mon Sep 17 00:00:00 2001 From: schneefux Date: Wed, 14 Jun 2017 13:12:41 +0200 Subject: apply workaround for match_pending notifications --- worker.js | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/worker.js b/worker.js index 0c67b84..f7cebb3 100644 --- a/worker.js +++ b/worker.js @@ -76,7 +76,10 @@ if (LOGGLY_TOKEN) await ch.sendToQueue(PROCESS_QUEUE, new Buffer(JSON.stringify(data)), { persistent: true, type: "match", - headers: idx == len - 1? { notify: notify } : {} + headers: { + notify: notify, + donotify: idx == len -1 // TODO remove this header, backwards compat for web + } }); // forward "notify" for the last match on the last page if (notify) await ch.publish("amq.topic", notify, -- cgit v1.3.1