public void stop()

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

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

  public void stop() {
    monitorTimer.cancel();
    publisher.cancel();
    if (publisherThread != null) {
      try {
        publisherThread.join();
      } catch (InterruptedException e) {
        // Do nothing
      }
    }
    session.disconnect();
  }