aboutsummaryrefslogtreecommitdiffstats
path: root/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/SubsetServicePolicy.java
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2019-04-13 22:19:36 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2019-04-13 22:19:36 +0200
commitec4e295270f95e36719b7fbbf660125b871bf489 (patch)
tree4c69c3db84bf45b8efcafaaaf673c1d8e0e1ec5f /documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/SubsetServicePolicy.java
parentb542fb6b05da7af5c0cda231231d3858bcd9b3d6 (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-xdocumentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/SubsetServicePolicy.java16
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;
- }
}