private synchronized void ensurePublisherThreadStarted()

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

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

  private synchronized void ensurePublisherThreadStarted() {
    if (publisherThread == null || !publisherThread.isAlive()) {
      logger.atInfo().log("Creating new publisher thread.");
      publisherThread = new Thread(publisher);
      publisherThread.setName("rabbitmq-publisher");
      publisherThread.start();
    }
  }