Merge "Bug 509: Improve logging in InMemoryDataStore."
[controller.git] / opendaylight / md-sal / sal-dom-broker / src / main / java / org / opendaylight / controller / sal / dom / broker / osgi / RpcProvisionRegistryProxy.java
1 /*
2  * Copyright (c) 2013 Cisco Systems, Inc. and others.  All rights reserved.
3  *
4  * This program and the accompanying materials are made available under the
5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6  * and is available at http://www.eclipse.org/legal/epl-v10.html
7  */
8
9 package org.opendaylight.controller.sal.dom.broker.osgi;
10
11 import java.util.Set;
12
13 import org.opendaylight.controller.md.sal.common.api.routing.RouteChangeListener;
14 import org.opendaylight.controller.sal.core.api.*;
15 import org.opendaylight.yangtools.concepts.ListenerRegistration;
16 import org.opendaylight.yangtools.yang.common.QName;
17 import org.opendaylight.yangtools.yang.common.RpcResult;
18 import org.opendaylight.yangtools.yang.data.api.CompositeNode;
19 import org.opendaylight.yangtools.yang.data.api.InstanceIdentifier;
20 import org.osgi.framework.ServiceReference;
21
22 import com.google.common.util.concurrent.ListenableFuture;
23
24 public class RpcProvisionRegistryProxy extends AbstractBrokerServiceProxy<RpcProvisionRegistry>
25                                        implements RpcProvisionRegistry {
26
27     public RpcProvisionRegistryProxy(ServiceReference<RpcProvisionRegistry> ref, RpcProvisionRegistry delegate) {
28         super(ref, delegate);
29     }
30
31     @Override
32     public Broker.RpcRegistration addRpcImplementation(QName rpcType, RpcImplementation implementation) throws IllegalArgumentException {
33         return getDelegate().addRpcImplementation(rpcType, implementation);
34     }
35
36     @Override
37     public ListenerRegistration<RpcRegistrationListener> addRpcRegistrationListener(RpcRegistrationListener listener) {
38         return getDelegate().addRpcRegistrationListener(listener);
39     }
40
41     @Override
42     public Broker.RoutedRpcRegistration addRoutedRpcImplementation(QName rpcType, RpcImplementation implementation) {
43         return getDelegate().addRoutedRpcImplementation(rpcType, implementation);
44     }
45
46     @Override
47     public void setRoutedRpcDefaultDelegate(RoutedRpcDefaultImplementation defaultImplementation) {
48         getDelegate().setRoutedRpcDefaultDelegate(defaultImplementation);
49     }
50
51     @Override
52     public <L extends RouteChangeListener<RpcRoutingContext, InstanceIdentifier>> ListenerRegistration<L> registerRouteChangeListener(L listener) {
53         return getDelegate().registerRouteChangeListener(listener);
54     }
55
56     @Override
57     public Set<QName> getSupportedRpcs() {
58         return getDelegate().getSupportedRpcs();
59     }
60
61     @Override
62     public ListenableFuture<RpcResult<CompositeNode>> invokeRpc(QName rpc, CompositeNode input) {
63         return getDelegate().invokeRpc(rpc, input);
64     }
65 }