public void start()

in src/main/java/com/googlesource/gerrit/plugins/rabbitmq/message/MessagePublisher.java [131:148]

• 18 lines of code
• 3 McCabe index (conditional complexity)

  public void start() {
    ensurePublisherThreadStarted();
    if (!isConnected()) {
      connect();
      monitorTimer.schedule(
          new TimerTask() {
            @Override
            public void run() {
              if (!isConnected()) {
                logger.atInfo().log("#start: try to reconnect");
                connect();
              }
            }
          },
          MONITOR_FIRSTTIME_DELAY,
          properties.getSection(Monitor.class).interval);
    }
  }