diff --git a/OpenAuth.WebApi/Startup.cs b/OpenAuth.WebApi/Startup.cs index aefb7d9..11cd4c6 100644 --- a/OpenAuth.WebApi/Startup.cs +++ b/OpenAuth.WebApi/Startup.cs @@ -328,7 +328,14 @@ namespace OpenAuth.WebApi #endregion #region mqtt - services.AddSingleton(); + //services.AddSingleton(); + services.AddSingleton(sp => + { + var mqtt = new MqttMessageCenter(); + var handlers = sp.GetServices(); + mqtt.InitializeAsync(handlers, "175.27.168.120", 6011, "mqtt_client_15821").GetAwaiter().GetResult(); + return mqtt; + }); services.AddSingleton(); services.AddSingleton(); services.AddSingleton();