前置日志联调
This commit is contained in:
@@ -38,7 +38,7 @@ public class ScheduledProducer {
|
|||||||
FrontHeartBeatDTO frontHeartBeatDTO = new FrontHeartBeatDTO();
|
FrontHeartBeatDTO frontHeartBeatDTO = new FrontHeartBeatDTO();
|
||||||
frontHeartBeatDTO.setNodeId("7d67349a44a9a4e1d02417f31e310a28");
|
frontHeartBeatDTO.setNodeId("7d67349a44a9a4e1d02417f31e310a28");
|
||||||
frontHeartBeatDTO.setStatus("1");
|
frontHeartBeatDTO.setStatus("1");
|
||||||
frontHeartBeatDTO.setProcessNum(1);
|
frontHeartBeatDTO.setProcessNo(1);
|
||||||
// 6. 每30秒执行一次消息发送
|
// 6. 每30秒执行一次消息发送
|
||||||
scheduler.scheduleAtFixedRate(() -> {
|
scheduler.scheduleAtFixedRate(() -> {
|
||||||
try {
|
try {
|
||||||
|
|||||||
Reference in New Issue
Block a user