try {
          await this.processIncomingQueries()
        } catch (e) {
          this.logger?.error?.(`Error in main loop: ${e}`)
        } finally {