diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2020-08-04 18:34:18 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2020-08-04 18:34:18 +0000 |
commit | af72753359ee72003d10d92e3c7355a156d3e6d7 (patch) | |
tree | df01de4919739a944082c72a2d805482a625e9e9 /metrics-proxy | |
parent | bd3399a2677b32888ef2588adf1c976ed4cdb5cb (diff) |
Name the transport threads to understand how things are interconnected.
Diffstat (limited to 'metrics-proxy')
-rw-r--r-- | metrics-proxy/src/main/java/ai/vespa/metricsproxy/rpc/RpcConnector.java | 3 | ||||
-rw-r--r-- | metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/ConfigSentinelClient.java | 2 |
2 files changed, 3 insertions, 2 deletions
diff --git a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/rpc/RpcConnector.java b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/rpc/RpcConnector.java index c09dc44d3fd..c9d4ad2a5ac 100644 --- a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/rpc/RpcConnector.java +++ b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/rpc/RpcConnector.java @@ -23,10 +23,11 @@ import static java.util.logging.Level.INFO; public class RpcConnector extends AbstractComponent { private static final Logger log = Logger.getLogger(RpcConnector.class.getName()); - private final Supervisor supervisor = new Supervisor(new Transport()); + private final Supervisor supervisor; private final Acceptor acceptor; public RpcConnector(RpcConnectorConfig config) { + supervisor = new Supervisor(new Transport("rpc-" + config.port())); Spec spec = new Spec(config.port()); try { acceptor = supervisor.listen(spec); diff --git a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/ConfigSentinelClient.java b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/ConfigSentinelClient.java index c0e3e636aa6..1fd444332d6 100644 --- a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/ConfigSentinelClient.java +++ b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/ConfigSentinelClient.java @@ -24,7 +24,7 @@ import java.util.logging.Logger; public class ConfigSentinelClient extends AbstractComponent { private final static Logger log = Logger.getLogger(ConfigSentinelClient.class.getName()); - private final Supervisor supervisor = new Supervisor(new Transport()); + private final Supervisor supervisor = new Supervisor(new Transport("sentinel-client")); @Inject public ConfigSentinelClient() { |