diff options
| -rw-r--r-- | streaming/index.js | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/streaming/index.js b/streaming/index.js index 74cbf4c2c..47f938b86 100644 --- a/streaming/index.js +++ b/streaming/index.js @@ -197,10 +197,12 @@ const startWorker = async (workerId) => { /** * @param {string} channel + * @param {function(string): void} callback */ - const unsubscribe = (channel) => { + const unsubscribe = (channel, callback) => { + log.silly(`Removing listener for ${channel}`); - redisSubscribeClient.unsubscribe(channel); + redisSubscribeClient.unsubscribe(channel, callback); }; const FALSE_VALUES = [ |