Java: using concurrent hash maps; Py: Added new ivy files

ipaacalib/java/src/ipaaca/IUStore.java

@@ -32,7 +32,7 @@
 
 package ipaaca;
 
-import java.util.HashMap;
+import java.util.concurrent.ConcurrentHashMap;
 
 /**
  * An IUStore maps an IUid to an IU
@@ -40,7 +40,7 @@ import java.util.HashMap;
  *
  * @param <X> type of AbstractIU stored in the store
  */
-public class IUStore<X extends AbstractIU> extends HashMap<String, X>
+public class IUStore<X extends AbstractIU> extends ConcurrentHashMap<String, X>
 {
     private static final long serialVersionUID = 1L;
 }

ipaacalib/java/src/ipaaca/InputBuffer.java

@@ -269,8 +269,16 @@ public class InputBuffer extends Buffer
         if (event.getData() instanceof RemoteMessageIU)
         {
             RemoteMessageIU rm = (RemoteMessageIU) event.getData();
+            if (messageStore.containsKey(rm.getUid())) {
+                logger.warn("Spurious RemoteMessage event: already got this UID: "+rm.getUid());
+                return;
+            }
+            
+            //logger.info("Adding Message "+rm.getUid());
             messageStore.put(rm.getUid(), rm);
+            //logger.info("Calling handlers for Message "+rm.getUid());
             callIuEventHandlers(rm.getUid(),false, IUEventType.MESSAGE, rm.getCategory());
+            //logger.info("Removing Message "+rm.getUid());
             messageStore.remove(rm.getUid());
         }
         else if (event.getData() instanceof RemotePushIU)

ipaacalib/python/ivy.xml

@@ -6,6 +6,8 @@
    <dependencies>
       <dependency org="google" name="protobuf-python" rev="latest.release"/>
       <dependency org="rsb" name="rsb-python" rev="latest.release"/>
+            <dependency org="spread" name="spread" rev="latest.release"/>
    </dependencies>
 
 </ivy-module>
+

ipaacalib/python/test/ivy.xml

@@ -3,5 +3,7 @@
    <dependencies>
 	<dependency org="hamcrest" name="hamcrest-python" rev="latest.release"/>
         <dependency org="mockito" name="mockito-python"  rev="latest.release" />
+        <dependency org="nose" name="nose"  rev="latest.release" />
    </dependencies>
 </ivy-module>
+