try {
      // Try removing directly from queue first
      const success = await this.queueService.removeJob(client, messageId);
      if (!success) {
        // Check why a job was not found