Browse Source

added handling of new messages to app actor

pull/13040/head
IrynaMatveieva 1 year ago
parent
commit
2cfa9a0103
  1. 2
      application/src/main/java/org/thingsboard/server/actors/app/AppActor.java
  2. 1
      application/src/main/java/org/thingsboard/server/actors/tenant/TenantActor.java

2
application/src/main/java/org/thingsboard/server/actors/app/AppActor.java

@ -113,6 +113,8 @@ public class AppActor extends ContextAwareActor {
case SESSION_TIMEOUT_MSG: case SESSION_TIMEOUT_MSG:
ctx.broadcastToChildrenByType(msg, EntityType.TENANT); ctx.broadcastToChildrenByType(msg, EntityType.TENANT);
break; break;
case CF_ACTOR_INIT_MSG:
case CF_PROFILE_ENTITY_MSG:
case CF_INIT_MSG: case CF_INIT_MSG:
case CF_LINK_INIT_MSG: case CF_LINK_INIT_MSG:
case CF_STATE_RESTORE_MSG: case CF_STATE_RESTORE_MSG:

1
application/src/main/java/org/thingsboard/server/actors/tenant/TenantActor.java

@ -282,6 +282,7 @@ public class TenantActor extends RuleChainManagerActor {
log.info("[{}] Failed to init CF Actor.", tenantId, e); log.info("[{}] Failed to init CF Actor.", tenantId, e);
} }
} }
cfActor.tellWithHighPriority(msg);
if (!ruleChainsInitialized) { if (!ruleChainsInitialized) {
log.info("Tenant {} is now managed by this service, initializing rule chains", tenantId); log.info("Tenant {} is now managed by this service, initializing rule chains", tenantId);
initRuleChains(); initRuleChains();

Loading…
Cancel
Save