1 files changed, 12 insertions, 3 deletions
diff --git a/server.js b/server.js
index f504f61..4c12fe2 100644
--- a/server.js
+++ b/server.js
@@ -158,7 +158,10 @@ async function grabPlayer(name, region, last_match_created_date, id, category) {
                 new Buffer(JSON.stringify(payload)), {
             persistent: true,
             type: "matches",
-            headers: { notify: "player." + name }
+            headers: {
+                donotify: true,  // TODO backwards compat
+                notify: "player." + name
+            }
         });
 
         part_start = part_end;
@@ -186,7 +189,10 @@ async function grabPlayers(names, region, grabstart, category) {
             new Buffer(JSON.stringify(payload)), {
         persistent: true,
         type: "matches",
-        headers: { notify: "player." + names }
+        headers: {
+            donotify: true,  // TODO
+            notify: "player." + names
+        }
     });
 }
 
@@ -237,7 +243,10 @@ async function searchPlayerInRegion(region, name, id) {
             await ch.sendToQueue(PLAYER_PROCESS_QUEUE,
                 new Buffer(JSON.stringify(player)), {
                     persistent: true, type: "player",
-                    headers: { notify: "player." + player.name }
+                    headers: {
+                        donotify: true,  // TODO
+                        notify: "player." + player.name
+                    }
                 });
             return player;
         }