Commit 1c16b3b6 by gdj

修改UOM上传频率为1s

parent 4c77d83a
...@@ -70,7 +70,7 @@ public class SDKDeviceService extends AbstractDeviceService { ...@@ -70,7 +70,7 @@ public class SDKDeviceService extends AbstractDeviceService {
private static final ScheduledExecutorService recordExecutor = Executors.newScheduledThreadPool(4); private static final ScheduledExecutorService recordExecutor = Executors.newScheduledThreadPool(4);
private static final Map<String, Long> lastRecordTimeMap = new ConcurrentHashMap<>(); private static final Map<String, Long> lastRecordTimeMap = new ConcurrentHashMap<>();
private static final long MIN_RECORD_INTERVAL = 2000; // 2秒间隔 private static final long MIN_RECORD_INTERVAL = 1000; // 1秒间隔
@Override @Override
public TopicStatusResponse<MqttReply> updateTopoOnline(TopicStatusRequest<UpdateTopo> request, MessageHeaders headers) { public TopicStatusResponse<MqttReply> updateTopoOnline(TopicStatusRequest<UpdateTopo> request, MessageHeaders headers) {
UpdateTopoSubDevice updateTopoSubDevice = request.getData().getSubDevices().get(0); UpdateTopoSubDevice updateTopoSubDevice = request.getData().getSubDevices().get(0);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment