This commit is contained in:
李鹏军 2024-04-10 19:51:46 +08:00
parent 8c81406e6e
commit 93417db522

View File

@ -90,7 +90,6 @@ namespace SJZY.Track.Application
// options.TopicNamePrefix = "v1"; // options.TopicNamePrefix = "v1";
options.FailedRetryInterval = configuration.GetValue<int>("CAP:FailedRetryInterval"); options.FailedRetryInterval = configuration.GetValue<int>("CAP:FailedRetryInterval");
options.FailedRetryCount = configuration.GetValue<int>("CAP:FailedRetryCount"); options.FailedRetryCount = configuration.GetValue<int>("CAP:FailedRetryCount");
options.UseDispatchingPerGroup = configuration.GetValue<bool>("CAP:UseDispatchingPerGroup");
options.ConsumerThreadCount = configuration.GetValue<int>("CAP:ConsumerThreadCount"); options.ConsumerThreadCount = configuration.GetValue<int>("CAP:ConsumerThreadCount");
options.SucceedMessageExpiredAfter = configuration.GetValue<int>("CAP:SucceedMessageExpiredAfter"); options.SucceedMessageExpiredAfter = configuration.GetValue<int>("CAP:SucceedMessageExpiredAfter");
options.UseDispatchingPerGroup = true; options.UseDispatchingPerGroup = true;