in src/main/java/com/googlesource/gerrit/plugins/pubsub/PubSubEventListener.java [39:45]
public void disconnect() {
try {
publisher.close();
} catch (InterruptedException e) {
logger.atSevere().withCause(e).log("Disconnect failed");
}
}