添加心跳逻辑
This commit is contained in:
parent
6927c9048c
commit
2b4e179cf9
|
@ -1,5 +1,6 @@
|
||||||
using MasstransferCommunicate.Mqtt.Client;
|
using MasstransferCommunicate.Mqtt.Client;
|
||||||
using MasstransferExporter.DataExporter;
|
using MasstransferExporter.DataExporter;
|
||||||
|
using MasstransferExporter.Stat;
|
||||||
using MasstransferInfrastructure.Mqtt.Model;
|
using MasstransferInfrastructure.Mqtt.Model;
|
||||||
|
|
||||||
class Program
|
class Program
|
||||||
|
@ -15,7 +16,7 @@ class Program
|
||||||
|
|
||||||
await MessageQueueHelper.InitConnect(options);
|
await MessageQueueHelper.InitConnect(options);
|
||||||
|
|
||||||
await SystemParamsService.SystemParamsExporter();
|
HeartbeatExporter.HeartBeat();
|
||||||
|
|
||||||
|
|
||||||
Console.WriteLine("按任意键退出");
|
Console.WriteLine("按任意键退出");
|
||||||
|
|
|
@ -1,4 +1,6 @@
|
||||||
using MasstransferCommon.Scheduler;
|
using MasstransferCommon.Model.Constant;
|
||||||
|
using MasstransferCommon.Scheduler;
|
||||||
|
using MasstransferCommunicate.Mqtt.Client;
|
||||||
|
|
||||||
namespace MasstransferExporter.Stat;
|
namespace MasstransferExporter.Stat;
|
||||||
|
|
||||||
|
@ -15,8 +17,10 @@ public class HeartbeatExporter
|
||||||
JobScheduler.AddTask("HeartbeatExporter#StartHeartBeat", HeartBeat, 10000);
|
JobScheduler.AddTask("HeartbeatExporter#StartHeartBeat", HeartBeat, 10000);
|
||||||
}
|
}
|
||||||
|
|
||||||
private static void HeartBeat()
|
public static async void HeartBeat()
|
||||||
{
|
{
|
||||||
|
var data = new Dictionary<string, DateTime>();
|
||||||
|
data["timestamp"] = DateTime.Now;
|
||||||
|
await MessageQueueHelper.Publish(Topics.HeartBeat, data);
|
||||||
}
|
}
|
||||||
}
|
}
|
Loading…
Reference in New Issue