StatsPersistTick singleton enum implementation
This commit is contained in:
parent
2c2273d15b
commit
f96d9c377a
@ -78,7 +78,7 @@ public abstract class ComponentMsgProcessor<T extends EntityId> extends Abstract
|
|||||||
}
|
}
|
||||||
|
|
||||||
public void scheduleStatsPersistTick(TbActorCtx context, long statsPersistFrequency) {
|
public void scheduleStatsPersistTick(TbActorCtx context, long statsPersistFrequency) {
|
||||||
schedulePeriodicMsgWithDelay(context, new StatsPersistTick(), statsPersistFrequency, statsPersistFrequency);
|
schedulePeriodicMsgWithDelay(context, StatsPersistTick.INSTANCE, statsPersistFrequency, statsPersistFrequency);
|
||||||
}
|
}
|
||||||
|
|
||||||
protected boolean checkMsgValid(TbMsg tbMsg) {
|
protected boolean checkMsgValid(TbMsg tbMsg) {
|
||||||
|
|||||||
@ -18,7 +18,9 @@ package org.thingsboard.server.actors.stats;
|
|||||||
import org.thingsboard.server.common.msg.MsgType;
|
import org.thingsboard.server.common.msg.MsgType;
|
||||||
import org.thingsboard.server.common.msg.TbActorMsg;
|
import org.thingsboard.server.common.msg.TbActorMsg;
|
||||||
|
|
||||||
public final class StatsPersistTick implements TbActorMsg {
|
public enum StatsPersistTick implements TbActorMsg {
|
||||||
|
INSTANCE;
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public MsgType getMsgType() {
|
public MsgType getMsgType() {
|
||||||
return MsgType.STATS_PERSIST_TICK_MSG;
|
return MsgType.STATS_PERSIST_TICK_MSG;
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user