Added sendAndReceive API to ClusterCommunicationService
diff --git a/core/api/src/main/java/org/onlab/onos/store/cluster/messaging/ClusterCommunicationService.java b/core/api/src/main/java/org/onlab/onos/store/cluster/messaging/ClusterCommunicationService.java
index 8b966ed..6fc150c 100644
--- a/core/api/src/main/java/org/onlab/onos/store/cluster/messaging/ClusterCommunicationService.java
+++ b/core/api/src/main/java/org/onlab/onos/store/cluster/messaging/ClusterCommunicationService.java
@@ -37,6 +37,15 @@
boolean multicast(ClusterMessage message, Set<NodeId> nodeIds) throws IOException;
/**
+ * Sends a message synchronously.
+ * @param message message to send
+ * @param toNodeId recipient node identifier
+ * @return ClusterMessageResponse which is reply future.
+ * @throws IOException
+ */
+ ClusterMessageResponse sendAndReceive(ClusterMessage message, NodeId toNodeId) throws IOException;
+
+ /**
* Adds a new subscriber for the specified message subject.
*
* @param subject message subject