dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Stats interval fixes

Browse Source
This commit is contained in:
Volodymyr Babak 2020-02-26 16:54:46 +02:00 committed by Andrew Shvayka
parent e563939c66
commit 57eeff3c12
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
application/src/main/java/org/thingsboard/server/actors/ActorSystemContext.java
View File

@ -295,7 +295,7 @@ public class ActorSystemContext {
@Getter @Getter
private final AtomicInteger jsInvokeFailuresCount = new AtomicInteger(0); private final AtomicInteger jsInvokeFailuresCount = new AtomicInteger(0);
@Scheduled(fixedDelayString = "${js.remote.stats.print_interval_ms}") @Scheduled(fixedDelayString = "${actors.statistics.js_print_interval_ms}")
public void printStats() { public void printStats() {
if (statisticsEnabled) { if (statisticsEnabled) {
if (jsInvokeRequestsCount.get() > 0 || jsInvokeResponsesCount.get() > 0 || jsInvokeFailuresCount.get() > 0) { if (jsInvokeRequestsCount.get() > 0 || jsInvokeResponsesCount.get() > 0 || jsInvokeFailuresCount.get() > 0) {

2
application/src/main/java/org/thingsboard/server/service/script/AbstractNashornJsInvokeService.java
View File

@ -70,7 +70,7 @@ public abstract class AbstractNashornJsInvokeService extends AbstractJsInvokeSer
@Value("${js.local.stats.enabled:false}") @Value("${js.local.stats.enabled:false}")
private boolean statsEnabled; private boolean statsEnabled;
@Scheduled(fixedDelayString = "${js.remote.stats.print_interval_ms:10000}") @Scheduled(fixedDelayString = "${js.local.stats.print_interval_ms:10000}")
public void printStats() { public void printStats() {
if (statsEnabled) { if (statsEnabled) {
int pushedMsgs = jsPushedMsgs.getAndSet(0); int pushedMsgs = jsPushedMsgs.getAndSet(0);