diff options
Diffstat (limited to 'documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutingPolicyRepository.java')
-rwxr-xr-x | documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutingPolicyRepository.java | 13 |
1 files changed, 3 insertions, 10 deletions
diff --git a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutingPolicyRepository.java b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutingPolicyRepository.java index 05bbb919805..098e0efc41c 100755 --- a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutingPolicyRepository.java +++ b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutingPolicyRepository.java @@ -1,7 +1,6 @@ // Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. package com.yahoo.documentapi.messagebus.protocol; -import com.yahoo.documentapi.metrics.DocumentProtocolMetricSet; import com.yahoo.messagebus.routing.RoutingPolicy; import com.yahoo.log.LogLevel; @@ -16,10 +15,8 @@ class RoutingPolicyRepository { private static final Logger log = Logger.getLogger(RoutingPolicyRepository.class.getName()); private final Map<String, RoutingPolicyFactory> factories = new ConcurrentHashMap<String, RoutingPolicyFactory>(); - private final DocumentProtocolMetricSet metrics; - RoutingPolicyRepository(DocumentProtocolMetricSet metrics) { - this.metrics = metrics; + RoutingPolicyRepository() { } /** @@ -38,7 +35,7 @@ class RoutingPolicyRepository { * @param name The name of the factory to return. * @return The routing policy factory matching the criteria, or null. */ - RoutingPolicyFactory getFactory(String name) { + private RoutingPolicyFactory getFactory(String name) { return factories.get(name); } @@ -55,7 +52,7 @@ class RoutingPolicyRepository { log.log(LogLevel.ERROR, "No routing policy factory found for name '" + name + "'."); return null; } - final DocumentProtocolRoutingPolicy ret = factory.createPolicy(param); + DocumentProtocolRoutingPolicy ret = factory.createPolicy(param); if (ret == null) { log.log(LogLevel.ERROR, "Routing policy factory " + factory.getClass().getName() + " failed to create a " + @@ -63,10 +60,6 @@ class RoutingPolicyRepository { return null; } - if (ret.getMetrics() != null) { - metrics.routingPolicyMetrics.addMetric(ret.getMetrics()); - } - return ret; } } |