diff options
author | Bjørn Christian Seime <bjorn.christian@seime.no> | 2019-01-15 15:19:59 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2019-01-15 15:19:59 +0100 |
commit | c97d2a7fbde4e30749164e3f3cef947a9c20d5db (patch) | |
tree | d54348a1f9aa0bf861761277fca1b3a2b5e4bffd /config/src | |
parent | 7b210b2bda57003de6fff1dbe28348fe6685fa0c (diff) | |
parent | 87ca5c6c4159ae5a7e44417e6624bd2d0ecb073d (diff) |
Merge pull request #8141 from vespa-engine/bjorncs/jrt-transport-metrics-cfgserver
Bjorncs/jrt transport metrics cfgserver
Diffstat (limited to 'config/src')
-rw-r--r-- | config/src/main/java/com/yahoo/vespa/config/JRTConnectionPool.java | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/config/src/main/java/com/yahoo/vespa/config/JRTConnectionPool.java b/config/src/main/java/com/yahoo/vespa/config/JRTConnectionPool.java index efeaacf225b..82306276617 100644 --- a/config/src/main/java/com/yahoo/vespa/config/JRTConnectionPool.java +++ b/config/src/main/java/com/yahoo/vespa/config/JRTConnectionPool.java @@ -28,7 +28,7 @@ public class JRTConnectionPool implements ConnectionPool { private static final Logger log = Logger.getLogger(JRTConnectionPool.class.getName()); - private final Supervisor supervisor = new Supervisor(new Transport()); + private final Supervisor supervisor; private final Map<String, JRTConnection> connections = new LinkedHashMap<>(); // The config sources used by this connection pool. @@ -38,6 +38,11 @@ public class JRTConnectionPool implements ConnectionPool { private volatile JRTConnection currentConnection; public JRTConnectionPool(ConfigSourceSet sourceSet) { + this(new Supervisor(new Transport()), sourceSet); + } + + public JRTConnectionPool(Supervisor supervisor, ConfigSourceSet sourceSet) { + this.supervisor = supervisor; addSources(sourceSet); } |