Issue 30128 system table clusterwide (#30146)

Now the system table updates are cluster wide --------- Co-authored-by: freddyDOTCMS <[email protected]> Co-authored-by: Jose Castro <[email protected]> Co-authored-by: freddyDOTCMS <[email protected]>
dotCMS · Sep 26, 2024 · a0dcbe6 · a0dcbe6
1 parent 34b682f
commit a0dcbe6
Showing 1 changed file with 12 additions and 2 deletions.
diff --git a/dotCMS/src/main/java/com/dotcms/business/SystemTableImpl.java b/dotCMS/src/main/java/com/dotcms/business/SystemTableImpl.java
@@ -1,5 +1,7 @@
 package com.dotcms.business;
 
+import com.dotcms.api.system.event.Payload;
+import com.dotcms.api.system.event.SystemEventType;
 import com.dotcms.rest.api.v1.maintenance.JVMInfoResource;
 import com.dotmarketing.business.APILocator;
 import com.dotmarketing.business.FactoryLocator;
@@ -79,7 +81,15 @@ public void delete(String key) {
         Try.run(()-> this.systemTableFactory.delete(key))
                 .getOrElseThrow((e)-> new DotRuntimeException(e.getMessage(), e));
 
-        Try.run(()->HibernateUtil.addCommitListener(()->
-                APILocator.getLocalSystemEventsAPI().asyncNotify(new SystemTableUpdatedKeyEvent(key))));
+        Try.run(()->HibernateUtil.addCommitListener(()-> {
+
+                    final SystemTableUpdatedKeyEvent systemTableUpdatedKeyEvent = new SystemTableUpdatedKeyEvent(key);
+                    // first notify the local system events
+                    APILocator.getLocalSystemEventsAPI().asyncNotify(systemTableUpdatedKeyEvent);
+                    // then notify the cluster wide events
+                    Try.run(()->APILocator.getSystemEventsAPI()					    // CLUSTER WIDE
+                            .push(SystemEventType.CLUSTER_WIDE_EVENT, new Payload(systemTableUpdatedKeyEvent)))
+                    .onFailure(e -> Logger.error(SystemTableImpl.class, e.getMessage()));
+                }));
     }
 }