Browse Source
Merge pull request #5030 from smatvienko-tb/fix-startup-warn-on-rule-chains-initialize
[3.3.0] fixed warn message on startup: Rule Chains initialized by unexpected message: PartitionChangeMsg ...
pull/5039/head
Igor Kulikov
5 years ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with
2 additions and
2 deletions
-
application/src/main/java/org/thingsboard/server/actors/app/AppActor.java
|
|
@ -55,7 +55,7 @@ public class AppActor extends ContextAwareActor { |
|
|
private final TbTenantProfileCache tenantProfileCache; |
|
|
private final TbTenantProfileCache tenantProfileCache; |
|
|
private final TenantService tenantService; |
|
|
private final TenantService tenantService; |
|
|
private final Set<TenantId> deletedTenants; |
|
|
private final Set<TenantId> deletedTenants; |
|
|
private boolean ruleChainsInitialized; |
|
|
private volatile boolean ruleChainsInitialized; |
|
|
|
|
|
|
|
|
private AppActor(ActorSystemContext systemContext) { |
|
|
private AppActor(ActorSystemContext systemContext) { |
|
|
super(systemContext); |
|
|
super(systemContext); |
|
|
@ -69,7 +69,7 @@ public class AppActor extends ContextAwareActor { |
|
|
if (!ruleChainsInitialized) { |
|
|
if (!ruleChainsInitialized) { |
|
|
initTenantActors(); |
|
|
initTenantActors(); |
|
|
ruleChainsInitialized = true; |
|
|
ruleChainsInitialized = true; |
|
|
if (msg.getMsgType() != MsgType.APP_INIT_MSG) { |
|
|
if (msg.getMsgType() != MsgType.APP_INIT_MSG && msg.getMsgType() != MsgType.PARTITION_CHANGE_MSG) { |
|
|
log.warn("Rule Chains initialized by unexpected message: {}", msg); |
|
|
log.warn("Rule Chains initialized by unexpected message: {}", msg); |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
|
