Updated the FlowId Hazelcast Notification Channel so the payload
is the Source Switch DPID. Thus, the receiver of the notification
can easily check which are the Flows it should fetch from the database.
diff --git a/src/main/java/net/onrc/onos/datagrid/IDatagridService.java b/src/main/java/net/onrc/onos/datagrid/IDatagridService.java
index cfc10bc..a855798 100644
--- a/src/main/java/net/onrc/onos/datagrid/IDatagridService.java
+++ b/src/main/java/net/onrc/onos/datagrid/IDatagridService.java
@@ -140,14 +140,15 @@
*
* @return all Flow IDs that ae currently in the datagrid.
*/
- Collection<FlowId> getAllFlowIds();
+ Collection<Pair<FlowId, Dpid>> getAllFlowIds();
/**
* Send a notification that a FlowId is added.
*
* @param flowId the FlowId that is added.
+ * @param dpid the Source Switch Dpid.
*/
- void notificationSendFlowIdAdded(FlowId flowId);
+ void notificationSendFlowIdAdded(FlowId flowId, Dpid dpid);
/**
* Send a notification that a FlowId is removed.
@@ -160,8 +161,9 @@
* Send a notification that a FlowId is updated.
*
* @param flowId the FlowId that is updated.
+ * @param dpid the Source Switch Dpid.
*/
- void notificationSendFlowIdUpdated(FlowId flowId);
+ void notificationSendFlowIdUpdated(FlowId flowId, Dpid dpid);
/**
* Send a notification that all Flow IDs are removed.