Merge pull request #36 from AthennaIO/develop

fix(handler): make a super call to handle method

Author: jlenon7

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@athenna/queue",
-  "version": "5.19.0",
+  "version": "5.20.0",
   "description": "The Athenna queue handler.",
   "license": "MIT",
   "author": "João Lenon <lenon@athenna.io>",

package.json

@@ -34,6 +34,10 @@ export class AwsSqsDriverExceptionHandler extends ExceptionHandler {
     const attempts = Math.max(driver.attempts - receiveCount, 0)
     const shouldRetry = attempts > 0
 
+    // eslint-disable-next-line @typescript-eslint/ban-ts-comment
+    // @ts-ignore
+    await super.handle({ job, error, driver, stopHeartbeat, requeueJitterMs })
+
     if (Config.is('worker.logger.enabled', true)) {
       if (Config.is('worker.logger.prettifyException')) {
         Log.channelOrVanilla('exception').error(

src/handlers/AwsSqsDriverExceptionHandler.ts

@@ -26,6 +26,10 @@ export class DatabaseDriverExceptionHandler extends ExceptionHandler {
   }: DatabaseDriverExceptionHandlerContext) {
     const shouldRetry = job.attempts > 0
 
+    // eslint-disable-next-line @typescript-eslint/ban-ts-comment
+    // @ts-ignore
+    await super.handle({ job, error, driver, requeueJitterMs })
+
     if (Config.is('worker.logger.enabled', true)) {
       if (Config.is('worker.logger.prettifyException')) {
         Log.channelOrVanilla('exception').error(

src/handlers/DatabaseDriverExceptionHandler.ts

@@ -26,6 +26,10 @@ export class MemoryDriverExceptionHandler extends ExceptionHandler {
   }: MemoryDriverExceptionHandlerContext) {
     const shouldRetry = job.attempts > 0
 
+    // eslint-disable-next-line @typescript-eslint/ban-ts-comment
+    // @ts-ignore
+    await super.handle({ job, error, driver, requeueJitterMs })
+
     job.reservedUntil = null
 
     if (Config.is('worker.logger.enabled', true)) {