Skip to content
Snippets Groups Projects
Commit e685c01a authored by Ayaka Koshibe's avatar Ayaka Koshibe
Browse files

added override for port value in FallbackCCProvider

amend to PR #443
parent fbfe13c4
No related branches found
No related tags found
No related merge requests found
...@@ -25,6 +25,7 @@ public class FallbackCCProvider implements IClusterConfigProvider { ...@@ -25,6 +25,7 @@ public class FallbackCCProvider implements IClusterConfigProvider {
AuthScheme authScheme; AuthScheme authScheme;
String keyStorePath; String keyStorePath;
String keyStorePassword; String keyStorePassword;
int syncPort = 6642;
public FallbackCCProvider() throws SyncException { public FallbackCCProvider() throws SyncException {
...@@ -43,7 +44,7 @@ public class FallbackCCProvider implements IClusterConfigProvider { ...@@ -43,7 +44,7 @@ public class FallbackCCProvider implements IClusterConfigProvider {
} }
return new ClusterConfig(Collections. return new ClusterConfig(Collections.
singletonList(new Node("localhost", singletonList(new Node("localhost",
6642, syncPort,
Short.MAX_VALUE, Short.MAX_VALUE,
Short.MAX_VALUE)), Short.MAX_VALUE)),
Short.MAX_VALUE, Short.MAX_VALUE,
...@@ -61,6 +62,7 @@ public class FallbackCCProvider implements IClusterConfigProvider { ...@@ -61,6 +62,7 @@ public class FallbackCCProvider implements IClusterConfigProvider {
authScheme = AuthScheme.NO_AUTH; authScheme = AuthScheme.NO_AUTH;
try { try {
authScheme = AuthScheme.valueOf(config.get("authScheme")); authScheme = AuthScheme.valueOf(config.get("authScheme"));
syncPort = Integer.parseInt(config.get("port"));
} catch (Exception e) {} } catch (Exception e) {}
} }
} }
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment