From 46ee67e6314f77843868bab952e36ced2e010a1b Mon Sep 17 00:00:00 2001 From: waterliu99 Date: Tue, 22 Oct 2019 10:12:33 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8DsessionKafka=E6=9C=8D?= =?UTF-8?q?=E5=8A=A1=EF=BC=8C=E6=9B=BF=E6=8D=A2=E9=BB=98=E8=AE=A4sessionKa?= =?UTF-8?q?fka=E6=9C=8D=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/JT808.DotNetty.Kafka/JT808ServerKafkaExtensions.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/JT808.DotNetty.Kafka/JT808ServerKafkaExtensions.cs b/src/JT808.DotNetty.Kafka/JT808ServerKafkaExtensions.cs index d2494ce..0c96d43 100644 --- a/src/JT808.DotNetty.Kafka/JT808ServerKafkaExtensions.cs +++ b/src/JT808.DotNetty.Kafka/JT808ServerKafkaExtensions.cs @@ -40,7 +40,7 @@ namespace JT808.DotNetty.Kafka public static IJT808NettyBuilder AddJT808ServerKafkaSessionProducer(this IJT808NettyBuilder jT808NettyBuilder, IConfiguration configuration) { jT808NettyBuilder.JT808Builder.Services.Configure(configuration.GetSection("JT808SessionProducerConfig")); - jT808NettyBuilder.JT808Builder.Services.TryAddSingleton(); + jT808NettyBuilder.JT808Builder.Services.Replace(new ServiceDescriptor(typeof(IJT808SessionProducer), typeof(JT808SessionProducer), ServiceLifetime.Singleton)); return jT808NettyBuilder; } }