Updated for moqui-framework multi-tenant removal

moqui · Sep 14, 2016 · 8b092c2 · 8b092c2
1 parent be3101b
commit 8b092c2
Showing 1 changed file with 2 additions and 7 deletions.
diff --git a/src/main/groovy/org/moqui/hazelcast/HazelcastDciTopicToolFactory.groovy b/src/main/groovy/org/moqui/hazelcast/HazelcastDciTopicToolFactory.groovy
@@ -96,14 +96,9 @@ class HazelcastDciTopicToolFactory implements ToolFactory<SimpleTopic<EntityCach
         @Override
         void onMessage(Message<EntityCacheInvalidate> message) {
             EntityCacheInvalidate eci = message.getMessageObject()
-            if (eci.tenantId == null) {
-                logger.warn("Received EntityCacheInvalidate message with null tenantId, ignoring")
-                return
-            }
             // logger.info("====== EntityCacheListener message tenantId=${eci.tenantId} isCreate=${eci.isCreate}, evb: ${eci.evb}")
-            ExecutionContextImpl.ThreadPoolRunnable runnable = new ExecutionContextImpl.ThreadPoolRunnable(ecfi, eci.tenantId, null, {
-                EntityFacadeImpl efi = ecfi.getEntityFacade(eci.tenantId)
-                efi.getEntityCache().clearCacheForValueActual(eci.evb, eci.isCreate)
+            ExecutionContextImpl.ThreadPoolRunnable runnable = new ExecutionContextImpl.ThreadPoolRunnable(ecfi, null, {
+                ecfi.entityFacade.getEntityCache().clearCacheForValueActual(eci.evb, eci.isCreate)
             })
             ecfi.workerPool.execute(runnable)
         }