From 2c5eeefbdc0bd8b3295799f2898feef70078269f Mon Sep 17 00:00:00 2001 From: Pritam Paul Date: Sun, 18 Jul 2021 00:28:05 -0400 Subject: [PATCH] fix: add missing thread kill which backs up memory (#125) * feat: fetch new executor-base version * fix: add missing thread kill which backs up memory --- receiver.js | 1 + 1 file changed, 1 insertion(+) diff --git a/receiver.js b/receiver.js index 93761d2..1845b1c 100644 --- a/receiver.js +++ b/receiver.js @@ -187,6 +187,7 @@ const onRetryMessage = async data => { } } channelWrapper.ack(data); + thread.kill(); }) .on('error', async error => { if (retryCount >= messageReprocessLimit) {