1 files changed, 4 insertions, 1 deletions
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,