Browse Source
Update TbRuleEngineProcessingStrategyFactory.java
pull/5470/head
Andrew Shvayka
5 years ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with
3 additions and
3 deletions
-
application/src/main/java/org/thingsboard/server/service/queue/processing/TbRuleEngineProcessingStrategyFactory.java
|
|
|
@ -78,7 +78,7 @@ public class TbRuleEngineProcessingStrategyFactory { |
|
|
|
@Override |
|
|
|
public TbRuleEngineProcessingDecision analyze(TbRuleEngineProcessingResult result) { |
|
|
|
if (result.isSuccess()) { |
|
|
|
log.debug("[{}] The result of the msg pack processing is successful, going to proceed with processing of the following msgs", queueName); |
|
|
|
log.trace("[{}] The result of the msg pack processing is successful, going to proceed with processing of the following msgs", queueName); |
|
|
|
return new TbRuleEngineProcessingDecision(true, null); |
|
|
|
} else { |
|
|
|
if (retryCount == 0) { |
|
|
|
@ -107,8 +107,8 @@ public class TbRuleEngineProcessingStrategyFactory { |
|
|
|
} |
|
|
|
if (retrySuccessful) { |
|
|
|
result.getSuccessMap().forEach(toReprocess::put); |
|
|
|
} else if (log.isDebugEnabled() && !result.getSuccessMap().isEmpty()) { |
|
|
|
log.debug("[{}] Skipped {} successful messages due to the processing strategy configuration", queueName, result.getSuccessMap().size()); |
|
|
|
} else if (log.isTraceEnabled() && !result.getSuccessMap().isEmpty()) { |
|
|
|
log.trace("[{}] Skipped {} successful messages due to the processing strategy configuration", queueName, result.getSuccessMap().size()); |
|
|
|
} |
|
|
|
if (CollectionUtils.isEmpty(toReprocess)) { |
|
|
|
if (log.isDebugEnabled()) { |
|
|
|
|
