X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fblueprint%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fblueprint%2Fext%2FRoutedRpcMetadata.java;h=725e568785efd2bf2367335d7d9cc82210dc2417;hb=2d60632f7cf63712e8357a3cf3fc40d83366e5e6;hp=4b71d92e57be3b5b03b4f6460cb6061609c577a2;hpb=d98d5bca742bfdff6c23e27aca21da04b15c33dd;p=controller.git diff --git a/opendaylight/blueprint/src/main/java/org/opendaylight/controller/blueprint/ext/RoutedRpcMetadata.java b/opendaylight/blueprint/src/main/java/org/opendaylight/controller/blueprint/ext/RoutedRpcMetadata.java index 4b71d92e57..725e568785 100644 --- a/opendaylight/blueprint/src/main/java/org/opendaylight/controller/blueprint/ext/RoutedRpcMetadata.java +++ b/opendaylight/blueprint/src/main/java/org/opendaylight/controller/blueprint/ext/RoutedRpcMetadata.java @@ -34,7 +34,7 @@ class RoutedRpcMetadata implements ComponentFactoryMetadata { private final String implementationRefId; private ExtendedBlueprintContainer container; - RoutedRpcMetadata(String id, String interfaceName, String implementationRefId) { + RoutedRpcMetadata(final String id, final String interfaceName, final String implementationRefId) { this.id = id; this.interfaceName = interfaceName; this.implementationRefId = implementationRefId; @@ -56,12 +56,13 @@ class RoutedRpcMetadata implements ComponentFactoryMetadata { } @Override - public void init(ExtendedBlueprintContainer container) { - this.container = container; + public void init(final ExtendedBlueprintContainer newContainer) { + this.container = newContainer; LOG.debug("{}: In init", logName()); } + @SuppressWarnings("checkstyle:IllegalCatch") @Override public Object create() throws ComponentDefinitionException { RpcProviderRegistry rpcRegistry = (RpcProviderRegistry) container.getComponentInstance( @@ -70,7 +71,7 @@ class RoutedRpcMetadata implements ComponentFactoryMetadata { Object implementation = container.getComponentInstance(implementationRefId); try { - if(!RpcService.class.isAssignableFrom(implementation.getClass())) { + if (!RpcService.class.isAssignableFrom(implementation.getClass())) { throw new ComponentDefinitionException(String.format( "Implementation \"ref\" instance %s for \"%s\" is not an RpcService", implementation.getClass(), ROUTED_RPC_IMPLEMENTATION)); @@ -80,10 +81,10 @@ class RoutedRpcMetadata implements ComponentFactoryMetadata { interfaceName, implementation.getClass(), container.getBundleContext().getBundle(), ROUTED_RPC_IMPLEMENTATION); - if(rpcInterfaces.size() > 1) { + if (rpcInterfaces.size() > 1) { throw new ComponentDefinitionException(String.format( - "Implementation \"ref\" instance %s for \"%s\" implements more than one RpcService " + - "interface (%s). Please specify the exact \"interface\"", implementation.getClass(), + "Implementation \"ref\" instance %s for \"%s\" implements more than one RpcService " + + "interface (%s). Please specify the exact \"interface\"", implementation.getClass(), ROUTED_RPC_IMPLEMENTATION, rpcInterfaces)); } @@ -93,23 +94,22 @@ class RoutedRpcMetadata implements ComponentFactoryMetadata { implementation, rpcInterface); return rpcRegistry.addRoutedRpcImplementation(rpcInterface, (RpcService)implementation); - } catch(ComponentDefinitionException e) { + } catch (final ComponentDefinitionException e) { throw e; - } catch(Exception e) { + } catch (final Exception e) { throw new ComponentDefinitionException(String.format( "Error processing \"%s\" for %s", ROUTED_RPC_IMPLEMENTATION, implementation.getClass()), e); } } @Override - public void destroy(Object instance) { + public void destroy(final Object instance) { LOG.debug("{}: In destroy: instance: {}", logName(), instance); - (( RoutedRpcRegistration)instance).close(); + ((RoutedRpcRegistration)instance).close(); } private String logName() { - return (container != null ? container.getBundleContext().getBundle().getSymbolicName() : "") + - " (" + id + ")"; + return (container != null ? container.getBundleContext().getBundle().getSymbolicName() : "") + " (" + id + ")"; } }