diff options
Diffstat (limited to 'vespaclient-core/src/main/java/com/yahoo/clientmetrics/RouteMetricSet.java')
-rw-r--r-- | vespaclient-core/src/main/java/com/yahoo/clientmetrics/RouteMetricSet.java | 33 |
1 files changed, 7 insertions, 26 deletions
diff --git a/vespaclient-core/src/main/java/com/yahoo/clientmetrics/RouteMetricSet.java b/vespaclient-core/src/main/java/com/yahoo/clientmetrics/RouteMetricSet.java index c5469e8a4f1..21efd53d7a5 100644 --- a/vespaclient-core/src/main/java/com/yahoo/clientmetrics/RouteMetricSet.java +++ b/vespaclient-core/src/main/java/com/yahoo/clientmetrics/RouteMetricSet.java @@ -2,9 +2,6 @@ package com.yahoo.clientmetrics; import com.yahoo.messagebus.Reply; -import com.yahoo.metrics.Metric; -import com.yahoo.metrics.MetricSet; -import com.yahoo.metrics.SumMetric; import java.util.HashMap; import java.util.Map; @@ -12,9 +9,9 @@ import java.util.Map; /** * @author thomasg */ -public class RouteMetricSet extends MetricSet { +public class RouteMetricSet { - private final SumMetric sum; + private final String route; private final ProgressCallback callback; private final Map<Integer, MessageTypeMetricSet> typeMap = new HashMap<>(); @@ -24,28 +21,17 @@ public class RouteMetricSet extends MetricSet { } public RouteMetricSet(String route, ProgressCallback callback) { - super(route, "", "Messages sent to the named route", null); - sum = new SumMetric("total", "", "All kinds of messages sent to the given route", this); + this.route = route; this.callback = callback; } - @Override - public String getXMLTag() { - return "route"; - } - - private RouteMetricSet(RouteMetricSet source, CopyType copyType, MetricSet owner, boolean includeUnused) { - super(source, copyType, owner, includeUnused); - sum = null; - callback = null; - } + public Map<Integer, MessageTypeMetricSet> getMetrics() { return typeMap; } public void addReply(Reply r) { MessageTypeMetricSet type = typeMap.get(r.getMessage().getType()); if (type == null) { String msgName = r.getMessage().getClass().getSimpleName().replace("Message", ""); - type = new MessageTypeMetricSet(msgName, this); - sum.addMetricToSum(type); + type = new MessageTypeMetricSet(msgName); typeMap.put(r.getMessage().getType(), type); } @@ -61,12 +47,7 @@ public class RouteMetricSet extends MetricSet { } } - @Override - public Metric clone(CopyType type, MetricSet owner, boolean includeUnused) { - return new RouteMetricSet(this, type, owner, includeUnused); - } - - String getRoute() { - return getName(); + public String getRoute() { + return route; } } |