diff --git a/MasstransferExporter/Program.cs b/MasstransferExporter/Program.cs index 18cf2d3..349542a 100644 --- a/MasstransferExporter/Program.cs +++ b/MasstransferExporter/Program.cs @@ -1,5 +1,6 @@ using MasstransferCommunicate.Mqtt.Client; using MasstransferExporter.DataExporter; +using MasstransferExporter.Stat; using MasstransferInfrastructure.Mqtt.Model; class Program @@ -15,7 +16,7 @@ class Program await MessageQueueHelper.InitConnect(options); - await SystemParamsService.SystemParamsExporter(); + HeartbeatExporter.HeartBeat(); Console.WriteLine("按任意键退出"); diff --git a/MasstransferExporter/StatExporter/HeartbeatExporter.cs b/MasstransferExporter/StatExporter/HeartbeatExporter.cs index d7ceaef..a23f4de 100644 --- a/MasstransferExporter/StatExporter/HeartbeatExporter.cs +++ b/MasstransferExporter/StatExporter/HeartbeatExporter.cs @@ -1,4 +1,6 @@ -using MasstransferCommon.Scheduler; +using MasstransferCommon.Model.Constant; +using MasstransferCommon.Scheduler; +using MasstransferCommunicate.Mqtt.Client; namespace MasstransferExporter.Stat; @@ -15,8 +17,10 @@ public class HeartbeatExporter JobScheduler.AddTask("HeartbeatExporter#StartHeartBeat", HeartBeat, 10000); } - private static void HeartBeat() + public static async void HeartBeat() { - + var data = new Dictionary(); + data["timestamp"] = DateTime.Now; + await MessageQueueHelper.Publish(Topics.HeartBeat, data); } } \ No newline at end of file