设置消息队列推送

src/DataSharing.Host/StartupExtensions.cs

@@ -73,7 +73,7 @@ internal static class StartupExtensions
         else if (sharingConfig != null && sharingConfig.CityCode == ConfigurationConsts.LuZhou)//泸州
         {
             services.AddScoped<ISendTaskDataService, DataSharing.LuZhou.LuZhouSendTaskDataService>();
-             services.AddScoped<IPoliceService, HndService>();//110 
+            services.AddScoped<IPoliceService, HndService>();//110 
             services.AddScoped<ICityStateDataExchangeService, CityStateDataExchangeService>();//市州互转
             services.AddScoped<ILuZhou110Service, LuZhou110Service>();//泸州110
             services.AddScoped<ILZCityPortalSiteService, LZCityPortalSiteService>();//泸州市政府门户网站
@@ -130,7 +130,8 @@ internal static class StartupExtensions
             .AddValidatorsFromAssembly(typeof(ApplicationStartupExtensions).Assembly);
 
         //mq
-        services.AddMq(configuration);
+        //  services.AddMq(configuration);
+        services.AddMq(() => configuration.GetSection(nameof(MqConfiguration)).Get<MqConfiguration>());
 
         services.Configure<KestrelServerOptions>(options =>
         {

src/DataSharing.Host/config/appsettings.Development.json

@@ -50,6 +50,7 @@
   "MqConfiguration": {
     "DbConnectionString": "PORT=5432;DATABASE=fwmq;HOST=110.188.24.182;PASSWORD=fengwo11!!;USER ID=dev;",
     "UseDashBoard": true,
+    "FailedRetryCount": 5,
     "RabbitMq": {
       "UserName": "dev",
       "Password": "123456",

src/DataSharing/DataSharing.csproj

@@ -19,7 +19,7 @@
     <PackageReference Include="Mapster" Version="7.4.0" />
     <PackageReference Include="MediatR" Version="12.2.0" />
     <PackageReference Include="XF.EasyCaching" Version="1.0.6" />
-    <PackageReference Include="XF.Utility.MQ" Version="1.0.9" />
+    <PackageReference Include="XF.Utility.MQ" Version="1.0.10" />
   </ItemGroup>
 
   <ItemGroup>