public void run()

in wrapper/src/main/java/software/amazon/jdbc/plugin/limitless/LimitlessRouterMonitor.java [126:190]
59 lines of code
13 McCabe index (conditional complexity)

  public void run() {
    LOGGER.finest(() -> Messages.get(
        "LimitlessRouterMonitor.running",
        new Object[] {this.hostSpec.getHost()}));

    try {
      while (!this.stopped.get()) {
        TelemetryContext telemetryContext = telemetryFactory.openTelemetryContext(
            "limitless router monitor thread", TelemetryTraceLevel.TOP_LEVEL);
        telemetryContext.setAttribute("url", hostSpec.getUrl());
        try {
          this.openConnection();
          if (this.monitoringConn == null || this.monitoringConn.isClosed()) {
            continue;
          }
          List<HostSpec> newLimitlessRouters = queryHelper.queryForLimitlessRouters(this.monitoringConn,
              this.hostSpec.getPort());

          limitlessRouterCache.put(
              this.limitlessRouterCacheKey,
              newLimitlessRouters,
              TimeUnit.MILLISECONDS.toNanos(LimitlessRouterServiceImpl.MONITOR_DISPOSAL_TIME_MS.getLong(props)));

          LOGGER.finest(Utils.logTopology(newLimitlessRouters, "[limitlessRouterMonitor] Topology:"));
          TimeUnit.MILLISECONDS.sleep(this.intervalMs); // do not include this in the telemetry
        } catch (final Exception ex) {
          if (telemetryContext != null) {
            telemetryContext.setException(ex);
            telemetryContext.setSuccess(false);
          }
          throw ex;
        } finally {
          if (telemetryContext != null) {
            telemetryContext.closeContext();
          }
        }
      }
    } catch (final InterruptedException exception) {
      LOGGER.finest(
          () -> Messages.get(
              "LimitlessRouterMonitor.interruptedExceptionDuringMonitoring",
              new Object[] {this.hostSpec.getHost()}));
    } catch (final Exception ex) {
      // this should not be reached; log and exit thread
      if (LOGGER.isLoggable(Level.FINEST)) {
        LOGGER.log(
            Level.FINEST,
            Messages.get(
                "LimitlessRouterMonitor.exceptionDuringMonitoringStop",
                new Object[] {this.hostSpec.getHost()}),
            ex); // We want to print full trace stack of the exception.
      }
    } finally {
      this.stopped.set(true);
      try {
        if (this.monitoringConn != null && !this.monitoringConn.isClosed()) {
          this.monitoringConn.close();
        }
      } catch (final SQLException ex) {
        // ignore
      }
      this.monitoringConn = null;
    }

  }