diff options
| author | Jon Marius Venstad <venstad@gmail.com> | 2021-10-19 12:27:26 +0200 |
|---|---|---|
| committer | Jon Marius Venstad <venstad@gmail.com> | 2022-01-11 10:31:10 +0100 |
| commit | 762d9a8bfc1db2a792f4bb424d12e6bee0b4e65d (patch) | |
| tree | 6c351ccfde8a9d81bd81792b46f103cbd278176a /zookeeper-server | |
| parent | 86120cb18cdaf4e0bc8ab05f0c9206cc439ac014 (diff) | |
Shut down on container exit (not just let JVM die)
Diffstat (limited to 'zookeeper-server')
| -rw-r--r-- | zookeeper-server/zookeeper-server-common/src/main/java/com/yahoo/vespa/zookeeper/Reconfigurer.java | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/zookeeper-server/zookeeper-server-common/src/main/java/com/yahoo/vespa/zookeeper/Reconfigurer.java b/zookeeper-server/zookeeper-server-common/src/main/java/com/yahoo/vespa/zookeeper/Reconfigurer.java index 3305ae80fba..77811dd6bee 100644 --- a/zookeeper-server/zookeeper-server-common/src/main/java/com/yahoo/vespa/zookeeper/Reconfigurer.java +++ b/zookeeper-server/zookeeper-server-common/src/main/java/com/yahoo/vespa/zookeeper/Reconfigurer.java @@ -50,6 +50,11 @@ public class Reconfigurer extends AbstractComponent { this.sleeper = Objects.requireNonNull(sleeper); } + @Override + public void deconstruct() { + shutdown(); + } + QuorumPeer startOrReconfigure(ZookeeperServerConfig newConfig, VespaZooKeeperServer server, Supplier<QuorumPeer> quorumPeerCreator) { if (zooKeeperRunner == null) { |