ideship/track
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

opt：开启cap多线程

Browse Source
This commit is contained in:
李鹏军 2024-04-10 19:18:18 +08:00
parent 8e9f5931e4
commit 6ef5ba86cf
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/SJZY.Track.Application/SjzyTrackApplicationModule.cs
View File

@ -84,7 +84,13 @@ namespace SJZY.Track.Application
configure.UserName = configuration["RabbitMQ:UserName"]!; configure.UserName = configuration["RabbitMQ:UserName"]!;
configure.Password = configuration["RabbitMQ:Password"]!; configure.Password = configuration["RabbitMQ:Password"]!;
configure.Port = configuration.GetValue<int>("RabbitMQ:Port"); configure.Port = configuration.GetValue<int>("RabbitMQ:Port");
configure.BasicQosOptions =
new RabbitMQOptions.BasicQos(configuration.GetValue<ushort>("CAP:PrefetchCount"));
}); });
options.FailedRetryInterval = configuration.GetValue<int>("CAP:FailedRetryInterval");
options.FailedRetryCount = configuration.GetValue<int>("CAP:FailedRetryCount");
options.UseDispatchingPerGroup = configuration.GetValue<bool>("CAP:UseDispatchingPerGroup");
options.ConsumerThreadCount = configuration.GetValue<int>("CAP:ConsumerThreadCount");
// options.TopicNamePrefix = "v1"; // options.TopicNamePrefix = "v1";
options.SucceedMessageExpiredAfter = 6 * 60 * 60; options.SucceedMessageExpiredAfter = 6 * 60 * 60;