try {
          // Try promoting directly from queue first
          const success = await this.queueService.promoteJob(client, msg.messageId);
          if (!success) {
            // Check if message contents are still there