Code Review
/
controller.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Updated implementation of internal RPC Router for Binding-Aware Broker and added...
[controller.git]
/
opendaylight
/
md-sal
/
sal-binding-broker
/
src
/
main
/
java
/
org
/
opendaylight
/
controller
/
sal
/
binding
/
spi
/
RpcRouter.java
diff --git
a/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/sal/binding/spi/RpcRouter.java
b/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/sal/binding/spi/RpcRouter.java
index b7a42eda1f51db83ad4f147676f0aa128a681dcc..38e309f46d4d30e2c2c3eac25dfb2bcfcb21fa2c 100644
(file)
--- a/
opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/sal/binding/spi/RpcRouter.java
+++ b/
opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/sal/binding/spi/RpcRouter.java
@@
-7,6
+7,8
@@
*/
package org.opendaylight.controller.sal.binding.spi;
*/
package org.opendaylight.controller.sal.binding.spi;
+import java.util.Set;
+
import org.opendaylight.yangtools.yang.binding.BaseIdentity;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
import org.opendaylight.yangtools.yang.binding.RpcService;
import org.opendaylight.yangtools.yang.binding.BaseIdentity;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
import org.opendaylight.yangtools.yang.binding.RpcService;
@@
-31,6
+33,16
@@
public interface RpcRouter<T extends RpcService> {
* @return type of RpcService which is served by this instance of router.
*/
Class<T> getRpcServiceType();
* @return type of RpcService which is served by this instance of router.
*/
Class<T> getRpcServiceType();
+
+
+ /**
+ * Returns a instance of T which is associated with this router instance
+ * and routes messages based on routing tables.
+ *
+ * @return type of RpcService which is served by this instance of router.
+ */
+ T getInvocationProxy();
+
/**
* Returns a routing table for particular route context
/**
* Returns a routing table for particular route context
@@
-64,6
+76,8
@@
public interface RpcRouter<T extends RpcService> {
/**
*
*/
/**
*
*/
- void setDefaultService();
+ void setDefaultService(T service);
+
+ Set<Class<? extends BaseIdentity>> getContexts();
}
}