diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2019-04-13 22:19:36 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2019-04-13 22:19:36 +0200 |
commit | ec4e295270f95e36719b7fbbf660125b871bf489 (patch) | |
tree | 4c69c3db84bf45b8efcafaaaf673c1d8e0e1ec5f /documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/SubsetServicePolicy.java | |
parent | b542fb6b05da7af5c0cda231231d3858bcd9b3d6 (diff) |
Remove some unused metrics code and dewire it.
Diffstat (limited to 'documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/SubsetServicePolicy.java')
-rwxr-xr-x | documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/SubsetServicePolicy.java | 16 |
1 files changed, 7 insertions, 9 deletions
diff --git a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/SubsetServicePolicy.java b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/SubsetServicePolicy.java index d6499c196f4..31802f2872f 100755 --- a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/SubsetServicePolicy.java +++ b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/SubsetServicePolicy.java @@ -3,8 +3,10 @@ package com.yahoo.documentapi.messagebus.protocol; import com.yahoo.jrt.slobrok.api.Mirror; import com.yahoo.log.LogLevel; -import com.yahoo.messagebus.metrics.MetricSet; -import com.yahoo.messagebus.routing.*; +import com.yahoo.messagebus.routing.Hop; +import com.yahoo.messagebus.routing.Route; +import com.yahoo.messagebus.routing.RoutingContext; +import com.yahoo.messagebus.routing.VerbatimDirective; import java.util.ArrayList; import java.util.HashMap; @@ -21,7 +23,7 @@ public class SubsetServicePolicy implements DocumentProtocolRoutingPolicy { private static Logger log = Logger.getLogger(SubsetServicePolicy.class.getName()); private final int subsetSize; - private final Map<String, CacheEntry> cache = new HashMap<String, CacheEntry>(); + private final Map<String, CacheEntry> cache = new HashMap<>(); /** * Creates an instance of a subset service policy. The parameter string is parsed as an integer number that is the @@ -29,7 +31,7 @@ public class SubsetServicePolicy implements DocumentProtocolRoutingPolicy { * * @param param The number of services to include in the set. */ - public SubsetServicePolicy(String param) { + SubsetServicePolicy(String param) { int subsetSize = 5; if (param != null && param.length() > 0) { try { @@ -131,15 +133,11 @@ public class SubsetServicePolicy implements DocumentProtocolRoutingPolicy { * Defines the necessary cache data. */ private class CacheEntry { - private final List<Hop> recipients = new ArrayList<Hop>(); + private final List<Hop> recipients = new ArrayList<>(); private int generation = 0; private int offset = 0; } public void destroy() { } - - public MetricSet getMetrics() { - return null; - } } |