|
@@ -1,5 +1,6 @@
|
|
|
using Ai.AgentServer.Server;
|
|
|
using Ai.AgentServer.Server.Fuel;
|
|
|
+using Ai.AgentServer.Server.Mqtt_Ext;
|
|
|
using Microsoft.AspNetCore.Mvc;
|
|
|
using MQTTnet.Client;
|
|
|
using Newtonsoft.Json;
|
|
@@ -21,11 +22,14 @@ namespace Ai.AgentServer.Controllers
|
|
|
|
|
|
private readonly IMqttServer _mqttServer;
|
|
|
|
|
|
- public FCCController(ILogger<WeatherForecastController> logger, IHttpServer httpServer, IMqttServer mqttServer)
|
|
|
+ private readonly MqttClientConfig mqttClientConfig;
|
|
|
+
|
|
|
+ public FCCController(ILogger<WeatherForecastController> logger, IHttpServer httpServer, IMqttServer mqttServer,IConfiguration configuration)
|
|
|
{
|
|
|
_logger = logger;
|
|
|
_server = httpServer;
|
|
|
_mqttServer = mqttServer;
|
|
|
+ mqttClientConfig= configuration.GetSection("MqttSettings").Get<MqttClientConfig>();
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
@@ -56,7 +60,7 @@ namespace Ai.AgentServer.Controllers
|
|
|
public Task Init()
|
|
|
{
|
|
|
var client = new MqttClientService();
|
|
|
- client.MqttClientStart();
|
|
|
+ client.MqttClientStart(mqttClientConfig);
|
|
|
return Task.CompletedTask;
|
|
|
}
|
|
|
|