diff options
Diffstat (limited to 'documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutingPolicyFactories.java')
-rwxr-xr-x | documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutingPolicyFactories.java | 39 |
1 files changed, 7 insertions, 32 deletions
diff --git a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutingPolicyFactories.java b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutingPolicyFactories.java index 7b44a1a4f0d..a09faea73d2 100755 --- a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutingPolicyFactories.java +++ b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutingPolicyFactories.java @@ -3,34 +3,32 @@ package com.yahoo.documentapi.messagebus.protocol; /** * @author Simon Thoresen Hult + * @author jonmv */ -public abstract class RoutingPolicyFactories { +class RoutingPolicyFactories { + + private RoutingPolicyFactories() { } static class AndPolicyFactory implements RoutingPolicyFactory { public DocumentProtocolRoutingPolicy createPolicy(String param) { return new ANDPolicy(param); } - - - public void destroy() { - } } static class ContentPolicyFactory implements RoutingPolicyFactory { public DocumentProtocolRoutingPolicy createPolicy(String param) { return new ContentPolicy(param); } - - public void destroy() { - } } static class MessageTypePolicyFactory implements RoutingPolicyFactory { + private final String configId; public MessageTypePolicyFactory(String configId) { this.configId = configId; } + public DocumentProtocolRoutingPolicy createPolicy(String param) { return new MessageTypePolicy((param == null || param.isEmpty()) ? configId : param); } @@ -56,10 +54,6 @@ public abstract class RoutingPolicyFactories { } return ret; } - - - public void destroy() { - } } static class ExternPolicyFactory implements RoutingPolicyFactory { @@ -71,49 +65,30 @@ public abstract class RoutingPolicyFactories { } return ret; } - - - public void destroy() { - } } static class LocalServicePolicyFactory implements RoutingPolicyFactory { public DocumentProtocolRoutingPolicy createPolicy(String param) { return new LocalServicePolicy(param); } - - - public void destroy() { - } } static class RoundRobinPolicyFactory implements RoutingPolicyFactory { public DocumentProtocolRoutingPolicy createPolicy(String param) { return new RoundRobinPolicy(); } - - - public void destroy() { - } } static class LoadBalancerPolicyFactory implements RoutingPolicyFactory { public DocumentProtocolRoutingPolicy createPolicy(String param) { return new LoadBalancerPolicy(param); } - - - public void destroy() { - } } static class SubsetServicePolicyFactory implements RoutingPolicyFactory { public DocumentProtocolRoutingPolicy createPolicy(String param) { return new SubsetServicePolicy(param); } - - - public void destroy() { - } } + } |