public void disconnect()

in src/main/java/com/googlesource/gerrit/plugins/pubsub/PubSubBrokerApi.java [65:81]

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

  public void disconnect() {
    publishers
        .values()
        .forEach(
            publisher -> {
              try {
                publisher.close();
              } catch (InterruptedException e) {
                logger.atSevere().withCause(e).log("Disconnect failed");
              }
            });

    for (PubSubEventSubscriber subscriber : subscribers) {
      subscriber.shutdown();
    }
    subscribers.clear();
  }