diff --git a/services/JiShe.CollectBus.Application/Subscribers/SubscriberAppService.cs b/services/JiShe.CollectBus.Application/Subscribers/SubscriberAppService.cs index 3afc05f..569186b 100644 --- a/services/JiShe.CollectBus.Application/Subscribers/SubscriberAppService.cs +++ b/services/JiShe.CollectBus.Application/Subscribers/SubscriberAppService.cs @@ -20,6 +20,7 @@ using TouchSocket.Sockets; using Volo.Abp.Domain.Repositories; using System.Collections.Generic; using JiShe.CollectBus.Kafka.Internal; +using JiShe.CollectBus.IoTDB.Provider; namespace JiShe.CollectBus.Subscribers { @@ -47,7 +48,7 @@ namespace JiShe.CollectBus.Subscribers IServiceProvider serviceProvider, IRepository messageReceivedLoginEventRepository, IRepository messageReceivedHeartbeatEventRepository, - IIoTDbProvider dbProvider, + IoTDBProvider dbProvider, IMeterReadingRecordRepository meterReadingRecordsRepository) { _logger = logger;