#43: Simplified message set management

cristal-ise · Sep 11, 2019 · f28c205 · f28c205
1 parent a4fa576
commit f28c205
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/kernel/src/main/java/org/cristalise/kernel/persistency/ClusterStorageManager.java b/kernel/src/main/java/org/cristalise/kernel/persistency/ClusterStorageManager.java
@@ -511,8 +511,7 @@ public void commit(Object locker) throws PersistencyException {
             thisStore.commit(locker);
         }
         if(locker != null){
-            messageSet = proxyMessagesMap.get(locker);
-            proxyMessagesMap.remove(locker);
+            messageSet = proxyMessagesMap.remove(locker);
             if (messageSet != null){
                for (ProxyMessage message: messageSet){
                     Gateway.getProxyServer().sendProxyEvent(message);