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
