X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-binding-util%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmd%2Fsal%2Fbinding%2Futil%2FBindingContextUtils.java;fp=opendaylight%2Fmd-sal%2Fsal-binding-util%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmd%2Fsal%2Fbinding%2Futil%2FBindingContextUtils.java;h=eaca3417aaeeadbcbda516a775fe3ab367b6fe6a;hp=76457910fb9a1ec6e09d68edf9df87750252fb88;hb=3859df9beca8f13f1ff2b2744ed3470a1715bec3;hpb=083a04543a96ae862c48ccb4aaefc667f19d9f1e diff --git a/opendaylight/md-sal/sal-binding-util/src/main/java/org/opendaylight/controller/md/sal/binding/util/BindingContextUtils.java b/opendaylight/md-sal/sal-binding-util/src/main/java/org/opendaylight/controller/md/sal/binding/util/BindingContextUtils.java index 76457910fb..eaca3417aa 100644 --- a/opendaylight/md-sal/sal-binding-util/src/main/java/org/opendaylight/controller/md/sal/binding/util/BindingContextUtils.java +++ b/opendaylight/md-sal/sal-binding-util/src/main/java/org/opendaylight/controller/md/sal/binding/util/BindingContextUtils.java @@ -7,7 +7,7 @@ */ package org.opendaylight.controller.md.sal.binding.util; -import static com.google.common.base.Preconditions.checkNotNull; +import static java.util.Objects.requireNonNull; import com.google.common.collect.ClassToInstanceMap; import com.google.common.collect.MutableClassToInstanceMap; @@ -31,35 +31,34 @@ public final class BindingContextUtils { private BindingContextUtils() { } - public static ConsumerContext createConsumerContext(BindingAwareConsumer consumer, - ClassToInstanceMap serviceProvider) { - checkNotNull(consumer,"Consumer should not be null"); - checkNotNull(serviceProvider,"Service map should not be null"); - return new SingleConsumerContextImpl(serviceProvider); + public static ConsumerContext createConsumerContext(final BindingAwareConsumer consumer, + final ClassToInstanceMap serviceProvider) { + requireNonNull(consumer, "Consumer should not be null"); + return new SingleConsumerContextImpl(requireNonNull(serviceProvider, "Service map should not be null")); } - public static ProviderContext createProviderContext(BindingAwareProvider provider, - ClassToInstanceMap serviceProvider) { - checkNotNull(provider,"Provider should not be null"); - checkNotNull(serviceProvider,"Service map should not be null"); - return new SingleProviderContextImpl(serviceProvider); + public static ProviderContext createProviderContext(final BindingAwareProvider provider, + final ClassToInstanceMap serviceProvider) { + requireNonNull(provider, "Provider should not be null"); + return new SingleProviderContextImpl(requireNonNull(serviceProvider, "Service map should not be null")); } - public static ConsumerContext createConsumerContextAndInitialize(BindingAwareConsumer consumer, - ClassToInstanceMap serviceProvider) { + public static ConsumerContext createConsumerContextAndInitialize(final BindingAwareConsumer consumer, + final ClassToInstanceMap serviceProvider) { ConsumerContext context = createConsumerContext(consumer, serviceProvider); consumer.onSessionInitialized(context); return context; } - public static ProviderContext createProviderContextAndInitialize(BindingAwareProvider provider, - ClassToInstanceMap serviceProvider) { + public static ProviderContext createProviderContextAndInitialize(final BindingAwareProvider provider, + final ClassToInstanceMap serviceProvider) { ProviderContext context = createProviderContext(provider, serviceProvider); provider.onSessionInitiated(context); return context; } - public static T createContextProxyOrReturnService(Class service, T instance) { + public static T createContextProxyOrReturnService(final Class service, + final T instance) { // FIXME: Create Proxy return instance; } @@ -69,27 +68,27 @@ public final class BindingContextUtils { private ClassToInstanceMap alreadyRetrievedServices; private ClassToInstanceMap serviceProvider; - SingleConsumerContextImpl(ClassToInstanceMap serviceProvider) { + SingleConsumerContextImpl(final ClassToInstanceMap serviceProvider) { this.alreadyRetrievedServices = MutableClassToInstanceMap.create(); this.serviceProvider = serviceProvider; } @Override - public final T getRpcService(Class module) { + public final T getRpcService(final Class module) { return getSALService(RpcConsumerRegistry.class).getRpcService(module); } @Override - public final T getSALService(Class service) { - checkNotNull(service,"Service class should not be null."); - T potential = alreadyRetrievedServices.getInstance(service); + public final T getSALService(final Class service) { + T potential = alreadyRetrievedServices.getInstance(requireNonNull(service, + "Service class should not be null.")); if (potential != null) { return potential; } return tryToRetrieveSalService(service); } - private synchronized T tryToRetrieveSalService(Class service) { + private synchronized T tryToRetrieveSalService(final Class service) { final T potential = alreadyRetrievedServices.getInstance(service); if (potential != null) { return potential; @@ -111,26 +110,25 @@ public final class BindingContextUtils { } private static class SingleProviderContextImpl extends SingleConsumerContextImpl implements ProviderContext { - - SingleProviderContextImpl(ClassToInstanceMap serviceProvider) { + SingleProviderContextImpl(final ClassToInstanceMap serviceProvider) { super(serviceProvider); } @Override public >> ListenerRegistration - registerRouteChangeListener(L listener) { + registerRouteChangeListener(final L listener) { return getSALService(RpcProviderRegistry.class).registerRouteChangeListener(listener); } @Override - public RoutedRpcRegistration addRoutedRpcImplementation(Class type, - T implementation) throws IllegalStateException { + public RoutedRpcRegistration addRoutedRpcImplementation(final Class type, + final T implementation) { return getSALService(RpcProviderRegistry.class).addRoutedRpcImplementation(type, implementation); } @Override - public RpcRegistration addRpcImplementation(Class type, T implementation) - throws IllegalStateException { + public RpcRegistration addRpcImplementation(final Class type, + final T implementation) { return getSALService(RpcProviderRegistry.class).addRpcImplementation(type, implementation); } }