public void stop()

in src/main/java/com/googlesource/gerrit/plugins/rabbitmq/Manager.java [88:99]

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

  public void stop() {
    for (Publisher publisher : publisherList) {
      publisher.stop();
      String listenAs = publisher.getProperties().getSection(Gerrit.class).listenAs;
      if (!listenAs.isEmpty()) {
        userEventWorker.removePublisher(publisher);
      } else {
        defaultEventWorker.removePublisher(publisher);
      }
    }
    publisherList.clear();
  }