添加空值判断
parent
a985719f3e
commit
9d07444f65
|
|
@ -480,6 +480,8 @@ namespace OpenAuth.WebApi.Controllers.ServiceControllers
|
|||
}
|
||||
private MqttClientResp ParseClient(HashEntry[] entries)
|
||||
{
|
||||
if (entries == null || entries.Length == 0)
|
||||
return null;
|
||||
var dict = entries.ToDictionary(e => e.Name.ToString(), e => e.Value.ToString());
|
||||
return new MqttClientResp
|
||||
{
|
||||
|
|
|
|||
|
|
@ -329,10 +329,10 @@ namespace OpenAuth.WebApi
|
|||
|
||||
#region mqtt
|
||||
services.AddSingleton<MqttMessageCenter>();
|
||||
//services.AddSingleton<IMqttMessageHandler, ThingRequestHandler>();
|
||||
//services.AddSingleton<IMqttMessageHandler, ThingServiceHandler>();
|
||||
//services.AddSingleton<IMqttMessageHandler, ThingOsdHandler>();
|
||||
//services.AddSingleton<IMqttMessageHandler, ThingEventHandler>();
|
||||
services.AddSingleton<IMqttMessageHandler, ThingRequestHandler>();
|
||||
services.AddSingleton<IMqttMessageHandler, ThingServiceHandler>();
|
||||
services.AddSingleton<IMqttMessageHandler, ThingOsdHandler>();
|
||||
services.AddSingleton<IMqttMessageHandler, ThingEventHandler>();
|
||||
services.AddSingleton<IMqttMessageHandler, ThingDrcHandler>();
|
||||
services.AddHostedService<MqttHostedService>();
|
||||
|
||||
|
|
|
|||
Loading…
Reference in New Issue