try {
      const messages = await this.dataService.findMessagesByQuery(client, messageId, status, tag, transactionId);

      const integrityList = [];
      await Promise.all(messages.map(msg => {