This is an automated email from the ASF dual-hosted git repository. mmerli pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from efd641b [testclient] Remove unused variable and import (#12147) add 85f13fb PIP-45: Use Metadata SessionLost event to trigger broker shutdowns (#12146) No new revisions were added by this update. Summary of changes: conf/broker.conf | 6 +- .../broker/MetadataSessionExpiredPolicy.java | 8 + .../apache/pulsar/broker/ServiceConfiguration.java | 8 +- .../org/apache/pulsar/broker/ShutdownService.java | 4 + .../org/apache/pulsar/PulsarBrokerStarter.java | 14 +- .../pulsar/ZookeeperSessionExpiredHandlers.java | 91 --------- .../broker/MessagingServiceShutdownHook.java | 100 ---------- .../org/apache/pulsar/broker/PulsarService.java | 59 +++--- .../pulsar/broker/namespace/NamespaceService.java | 21 --- .../pulsar/functions/worker/ErrorNotifier.java | 5 +- .../worker/ErrorNotifierShutdownServiceImpl.java | 8 +- .../zookeeper/LocalZooKeeperConnectionService.java | 11 +- .../pulsar/zookeeper/ZooKeeperSessionWatcher.java | 190 ------------------- .../zookeeper/ZookeeperSessionExpiredHandler.java | 32 ---- .../LocalZooKeeperConnectionServiceTest.java | 22 +-- .../zookeeper/ZooKeeperSessionWatcherTest.java | 208 --------------------- 16 files changed, 72 insertions(+), 715 deletions(-) copy pulsar-broker/src/main/java/org/apache/pulsar/broker/package-info.java => pulsar-broker-common/src/main/java/org/apache/pulsar/broker/MetadataSessionExpiredPolicy.java (82%) copy pulsar-broker/src/main/java/org/apache/pulsar/broker/package-info.java => pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ShutdownService.java (93%) delete mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/ZookeeperSessionExpiredHandlers.java delete mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/MessagingServiceShutdownHook.java delete mode 100644 pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZooKeeperSessionWatcher.java delete mode 100644 pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZookeeperSessionExpiredHandler.java delete mode 100644 pulsar-zookeeper-utils/src/test/java/org/apache/pulsar/zookeeper/ZooKeeperSessionWatcherTest.java