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%2FAbstractBindingSalProviderInstance.java;h=5cc0340f56ad7c1a1615e2244990e3dbc2437e06;hp=2a8ebe869c76e8a4faead7f00f84b6005502d3ec;hb=deaaa394466f2140b7148470b4b83581f136de4e;hpb=405ea7ce68d22bd3d2501857c5253793b581b086 diff --git a/opendaylight/md-sal/sal-binding-util/src/main/java/org/opendaylight/controller/md/sal/binding/util/AbstractBindingSalProviderInstance.java b/opendaylight/md-sal/sal-binding-util/src/main/java/org/opendaylight/controller/md/sal/binding/util/AbstractBindingSalProviderInstance.java index 2a8ebe869c..5cc0340f56 100644 --- a/opendaylight/md-sal/sal-binding-util/src/main/java/org/opendaylight/controller/md/sal/binding/util/AbstractBindingSalProviderInstance.java +++ b/opendaylight/md-sal/sal-binding-util/src/main/java/org/opendaylight/controller/md/sal/binding/util/AbstractBindingSalProviderInstance.java @@ -8,95 +8,57 @@ package org.opendaylight.controller.md.sal.binding.util; import java.util.concurrent.ExecutorService; - -import org.opendaylight.controller.md.sal.common.api.RegistrationListener; -import org.opendaylight.controller.md.sal.common.api.data.DataCommitHandler; -import org.opendaylight.controller.md.sal.common.api.data.DataCommitHandlerRegistration; -import org.opendaylight.controller.md.sal.common.api.data.DataReader; import org.opendaylight.controller.md.sal.common.api.routing.RouteChangeListener; import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.RoutedRpcRegistration; import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.RpcRegistration; import org.opendaylight.controller.sal.binding.api.NotificationProviderService; import org.opendaylight.controller.sal.binding.api.RpcProviderRegistry; -import org.opendaylight.controller.sal.binding.api.data.DataProviderService; -import org.opendaylight.controller.sal.binding.api.mount.MountProviderInstance; import org.opendaylight.controller.sal.binding.api.rpc.RpcContextIdentifier; import org.opendaylight.yangtools.concepts.ListenerRegistration; -import org.opendaylight.yangtools.concepts.Registration; -import org.opendaylight.yangtools.yang.binding.DataObject; import org.opendaylight.yangtools.yang.binding.InstanceIdentifier; import org.opendaylight.yangtools.yang.binding.Notification; import org.opendaylight.yangtools.yang.binding.RpcService; -public abstract class AbstractBindingSalProviderInstance // - extends AbstractBindingSalConsumerInstance // - implements // - DataProviderService, // - RpcProviderRegistry, // - NotificationProviderService { - - public AbstractBindingSalProviderInstance(R rpcRegistry, N notificationBroker, - D dataBroker) { - super(rpcRegistry, notificationBroker, dataBroker); - } - - @Override - public Registration, DataObject>> registerDataReader( - InstanceIdentifier path, - DataReader, DataObject> reader) { - return getDataBrokerChecked().registerDataReader(path, reader); - } - - @Override - public Registration, DataObject>> registerCommitHandler( - InstanceIdentifier path, - DataCommitHandler, DataObject> commitHandler) { - return getDataBrokerChecked().registerCommitHandler(path, commitHandler); - } +public abstract class AbstractBindingSalProviderInstance + extends AbstractBindingSalConsumerInstance + implements RpcProviderRegistry, NotificationProviderService { - @Override - public ListenerRegistration, DataObject>>> registerCommitHandlerListener( - RegistrationListener, DataObject>> commitHandlerListener) { - return getDataBrokerChecked().registerCommitHandlerListener(commitHandlerListener); + public AbstractBindingSalProviderInstance(final R rpcRegistry, final N notificationBroker) { + super(rpcRegistry, notificationBroker); } @Override - public RpcRegistration addRpcImplementation(Class type, T implementation) + public RpcRegistration addRpcImplementation(final Class type, final T implementation) throws IllegalStateException { return getRpcRegistryChecked().addRpcImplementation(type, implementation); } @Override - public RoutedRpcRegistration addRoutedRpcImplementation(Class type, T implementation) - throws IllegalStateException { + public RoutedRpcRegistration addRoutedRpcImplementation(final Class type, + final T implementation) throws IllegalStateException { return getRpcRegistryChecked().addRoutedRpcImplementation(type, implementation); } @Override - @Deprecated - public void notify(Notification notification) { - getNotificationBrokerChecked().notify(notification); - } - - @Override - @Deprecated - public void notify(Notification notification, ExecutorService service) { - getNotificationBrokerChecked().notify(notification, service); - } - - @Override - public void publish(Notification notification) { + public void publish(final Notification notification) { getNotificationBrokerChecked().publish(notification); } @Override - public void publish(Notification notification, ExecutorService service) { + public void publish(final Notification notification, final ExecutorService service) { getNotificationBrokerChecked().publish(notification, service); } @Override - public >> ListenerRegistration registerRouteChangeListener( - L listener) { + public >> ListenerRegistration + registerRouteChangeListener(final L listener) { return getRpcRegistryChecked().registerRouteChangeListener(listener); } + + @Override + public ListenerRegistration registerInterestListener( + final NotificationInterestListener interestListener) { + return getNotificationBrokerChecked().registerInterestListener(interestListener); + } }