public void shutdown()

in src/main/java/com/googlesource/gerrit/plugins/pubsub/PubSubEventSubscriber.java [89:97]


  public void shutdown() {
    try {
      subscriber
          .stopAsync()
          .awaitTerminated(config.getShutdownTimeoutInSeconds(), TimeUnit.SECONDS);
    } catch (TimeoutException e) {
      logger.atSevere().withCause(e).log("Timeout during subscriber shutdown");
    }
  }