Refactored Proxy update notification server into its own class and

thread, so executions return before proxy messages are sent. Another
deadlock suspect.

1 files changed, 2 insertions, 3 deletions

diff --git a/src/main/java/com/c2kernel/persistency/ClusterStorageManager.java b/src/main/java/com/c2kernel/persistency/ClusterStorageManager.java
index d0c3f77..20857c6 100644
--- a/src/main/java/com/c2kernel/persistency/ClusterStorageManager.java
+++ b/src/main/java/com/c2kernel/persistency/ClusterStorageManager.java
@@ -10,7 +10,6 @@ import java.util.StringTokenizer;
 import com.c2kernel.common.ObjectNotFoundException;

 import com.c2kernel.entity.C2KLocalObject;

 import com.c2kernel.entity.agent.JobList;

-import com.c2kernel.entity.proxy.ProxyManager;

 import com.c2kernel.entity.proxy.ProxyMessage;

 import com.c2kernel.events.History;

 import com.c2kernel.persistency.outcome.Outcome;

@@ -291,7 +290,7 @@ public class ClusterStorageManager {
         if (Logger.doLog(9)) dumpCacheContents(9);

 

         // transmit proxy event

-        ProxyManager.sendProxyEvent( new ProxyMessage(sysKeyIntObj.intValue(), path, ProxyMessage.ADDED));

+        Gateway.getProxyServer().sendProxyEvent( new ProxyMessage(sysKeyIntObj.intValue(), path, ProxyMessage.ADDED));

     }

 

     /** Deletes a cluster from all writers */

@@ -317,7 +316,7 @@ public class ClusterStorageManager {
 

 

         // transmit proxy event

-        ProxyManager.sendProxyEvent( new ProxyMessage(sysKeyIntObj.intValue(), path, ProxyMessage.DELETED));

+        Gateway.getProxyServer().sendProxyEvent( new ProxyMessage(sysKeyIntObj.intValue(), path, ProxyMessage.DELETED));

     }

 

     public void clearCache(Integer sysKeyIntObj, String path) {