Addition of OpFlex server configuration and message support.

[groupbasedpolicy.git] / groupbasedpolicy / src / main / java / org / opendaylight / groupbasedpolicy / jsonrpc / RpcMessageMap.java

diff --git a/groupbasedpolicy/src/main/java/org/opendaylight/groupbasedpolicy/jsonrpc/JsonRpcMessageMap.java b/groupbasedpolicy/src/main/java/org/opendaylight/groupbasedpolicy/jsonrpc/RpcMessageMap.java
similarity index 53%
rename from groupbasedpolicy/src/main/java/org/opendaylight/groupbasedpolicy/jsonrpc/JsonRpcMessageMap.java
rename to groupbasedpolicy/src/main/java/org/opendaylight/groupbasedpolicy/jsonrpc/RpcMessageMap.java
index 936caf61e9aa5a217c781cd08f1c9ea3419521e1..cd1eb984d31f5fc99883e8fc1aa7e58d87a353e9 100644 (file)
--- a/groupbasedpolicy/src/main/java/org/opendaylight/groupbasedpolicy/jsonrpc/JsonRpcMessageMap.java
+++ b/groupbasedpolicy/src/main/java/org/opendaylight/groupbasedpolicy/jsonrpc/RpcMessageMap.java
@@ -9,22 +9,33 @@
  */
 package org.opendaylight.groupbasedpolicy.jsonrpc;
 
+import java.util.List;
 import java.util.Map;
 
 import com.google.common.collect.Maps;
 
-public class JsonRpcMessageMap {
-    private Map<String, JsonRpcMessage> messageMap;
-    
-    public JsonRpcMessageMap() {
+public class RpcMessageMap {
+    private Map<String, RpcMessage> messageMap;
+
+    public boolean containsMessages (List<RpcMessage> messages) {
+        return messages.containsAll(messageMap.values());
+    }
+
+    public RpcMessageMap() {
         messageMap = Maps.newHashMap();
     }
-    
-    public JsonRpcMessage get(String messageName) {
+
+    public RpcMessage get(String messageName) {
         return messageMap.get(messageName);
     }
 
-    public void add(JsonRpcMessage message) {
+    public void add(RpcMessage message) {
         messageMap.put(message.getName(), message);
     }
+
+    public void addList(List<RpcMessage> messages) {
+        for ( RpcMessage msg : messages ) {
+            this.add(msg);
+        }
+    }
 }