diff options
author | Martin Polden <mpolden@mpolden.no> | 2020-12-06 19:59:54 +0100 |
---|---|---|
committer | Martin Polden <mpolden@mpolden.no> | 2020-12-06 19:59:54 +0100 |
commit | d1290e2a8171e9ab008dd537e122bb1fb617fb33 (patch) | |
tree | 61a1e30a94ed532651a86a3a6076dfb0817d0631 /zookeeper-server/zookeeper-server-common/src/main/java | |
parent | 752438ce0da276442430490f462306de4515d354 (diff) |
Stop using deprecated clientPort statement
Diffstat (limited to 'zookeeper-server/zookeeper-server-common/src/main/java')
-rw-r--r-- | zookeeper-server/zookeeper-server-common/src/main/java/com/yahoo/vespa/zookeeper/Configurator.java | 17 |
1 files changed, 13 insertions, 4 deletions
diff --git a/zookeeper-server/zookeeper-server-common/src/main/java/com/yahoo/vespa/zookeeper/Configurator.java b/zookeeper-server/zookeeper-server-common/src/main/java/com/yahoo/vespa/zookeeper/Configurator.java index 001926346f2..df4b4e76c0b 100644 --- a/zookeeper-server/zookeeper-server-common/src/main/java/com/yahoo/vespa/zookeeper/Configurator.java +++ b/zookeeper-server/zookeeper-server-common/src/main/java/com/yahoo/vespa/zookeeper/Configurator.java @@ -79,7 +79,6 @@ public class Configurator { sb.append("maxClientCnxns=").append(config.maxClientConnections()).append("\n"); sb.append("snapCount=").append(config.snapshotCount()).append("\n"); sb.append("dataDir=").append(getDefaults().underVespaHome(config.dataDir())).append("\n"); - sb.append("clientPort=").append(config.clientPort()).append("\n"); sb.append("secureClientPort=").append(config.secureClientPort()).append("\n"); sb.append("autopurge.purgeInterval=").append(config.autopurge().purgeInterval()).append("\n"); sb.append("autopurge.snapRetainCount=").append(config.autopurge().snapRetainCount()).append("\n"); @@ -94,7 +93,7 @@ public class Configurator { sb.append("reconfigEnabled=true").append("\n"); sb.append("skipACL=yes").append("\n"); ensureThisServerIsRepresented(config.myid(), config.server()); - config.server().forEach(server -> addServerToCfg(sb, server)); + config.server().forEach(server -> addServerToCfg(sb, server, config.clientPort())); SSLContext sslContext = new SslContextBuilder().build(); sb.append(new TlsQuorumConfig(sslContext, jksKeyStoreFilePath).createConfig(config, transportSecurityOptions)); sb.append(new TlsClientServerConfig(sslContext, jksKeyStoreFilePath).createConfig(config, transportSecurityOptions)); @@ -139,8 +138,18 @@ public class Configurator { } } - private void addServerToCfg(StringBuilder sb, ZookeeperServerConfig.Server server) { - sb.append("server.").append(server.id()).append("=").append(server.hostname()).append(":").append(server.quorumPort()).append(":").append(server.electionPort()).append("\n"); + private void addServerToCfg(StringBuilder sb, ZookeeperServerConfig.Server server, int clientPort) { + sb.append("server.") + .append(server.id()) + .append("=") + .append(server.hostname()) + .append(":") + .append(server.quorumPort()) + .append(":") + .append(server.electionPort()) + .append(";") + .append(clientPort) + .append("\n"); } static Set<String> zookeeperServerHostnames(ZookeeperServerConfig zookeeperServerConfig) { |