diff options
Diffstat (limited to 'config-proxy/src')
-rw-r--r-- | config-proxy/src/main/java/com/yahoo/vespa/config/proxy/RpcConfigSourceClient.java | 15 |
1 files changed, 3 insertions, 12 deletions
diff --git a/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/RpcConfigSourceClient.java b/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/RpcConfigSourceClient.java index b5669820d1a..865bb2472c2 100644 --- a/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/RpcConfigSourceClient.java +++ b/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/RpcConfigSourceClient.java @@ -171,26 +171,17 @@ class RpcConfigSourceClient implements ConfigSourceClient { activeSubscribers.clear(); } exec.shutdown(); - if (requester != null) - requester.close(); + requester.close(); } @Override public String getActiveSourceConnection() { - if (requester != null) { - return requester.getConnectionPool().getCurrent().getAddress(); - } else { - return ""; - } + return requester.getConnectionPool().getCurrent().getAddress(); } @Override public List<String> getSourceConnections() { - ArrayList<String> ret = new ArrayList<>(); - if (requester != null) { - ret.addAll(configSourceSet.getSources()); - } - return ret; + return new ArrayList<>(configSourceSet.getSources()); } /** |