      );
      try {
        await handler(handlerParams as HandlerExtraParams & DataTypeOverrides);

        if (!messageBackoff) {
          channel.ack(message);
        }
      } catch (e: any) {
        await failThisMessage(e);
      }
    },
    {
      consumerTag,