Code Review
/
controller.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Bump cds-access-api ABIVersion
[controller.git]
/
opendaylight
/
md-sal
/
sal-connector-api
/
src
/
main
/
java
/
org
/
opendaylight
/
controller
/
sal
/
connector
/
api
/
RpcRouter.java
diff --git
a/opendaylight/md-sal/sal-connector-api/src/main/java/org/opendaylight/controller/sal/connector/api/RpcRouter.java
b/opendaylight/md-sal/sal-connector-api/src/main/java/org/opendaylight/controller/sal/connector/api/RpcRouter.java
index fa4c8048fac87e1e218b45d6508f78274b14a75c..c56560ac75f074f9ba735916c6a709e6f0de62c0 100644
(file)
--- a/
opendaylight/md-sal/sal-connector-api/src/main/java/org/opendaylight/controller/sal/connector/api/RpcRouter.java
+++ b/
opendaylight/md-sal/sal-connector-api/src/main/java/org/opendaylight/controller/sal/connector/api/RpcRouter.java
@@
-10,6
+10,7
@@
package org.opendaylight.controller.sal.connector.api;
import java.util.concurrent.Future;
/**
import java.util.concurrent.Future;
/**
+ * Interface for an RPC router.
*
* @author ttkacik
*
*
* @author ttkacik
*
@@
-19,35
+20,34
@@
import java.util.concurrent.Future;
* @param <D> Data Type
*/
public interface RpcRouter<C,T,R,D> {
* @param <D> Data Type
*/
public interface RpcRouter<C,T,R,D> {
-
-
-
Future<RpcReply<D>> sendRpc(RpcRequest<C, T, R, D> input);
/**
Future<RpcReply<D>> sendRpc(RpcRequest<C, T, R, D> input);
/**
- *
- * @author
+ * Interface for an RPC request.
*
* @param <C> Routing Context Identifier
*
* @param <C> Routing Context Identifier
-
* @param <R> Route Type
-
* @param <T> Rpc Type
-
* @param <D> Data Type
+ * @param <R> Route Type
+ * @param <T> Rpc Type
+ * @param <D> Data Type
*/
*/
-
public
interface RpcRequest<C,T,R,D> {
+ interface RpcRequest<C,T,R,D> {
RouteIdentifier<C,T,R> getRoutingInformation();
RouteIdentifier<C,T,R> getRoutingInformation();
+
D getPayload();
}
D getPayload();
}
-
public
interface RouteIdentifier<C,T,R> {
+ interface RouteIdentifier<C,T,R> {
C getContext(); // defines a routing table (e.g. NodeContext)
C getContext(); // defines a routing table (e.g. NodeContext)
+
T getType(); // rpc type
T getType(); // rpc type
+
R getRoute(); // e.g. (node identity)
}
R getRoute(); // e.g. (node identity)
}
-
public
interface RpcReply<D> {
+ interface RpcReply<D> {
D getPayload();
}
}
D getPayload();
}
}