summaryrefslogtreecommitdiffstats
path: root/vespaclient-core/src/main/java/com/yahoo/clientmetrics/RouteMetricSet.java
diff options
context:
space:
mode:
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.java33
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;
}
}