Browse Source

feat(cap): use `IProcessingServer.StartAsync`

pull/1416/head
colin 3 months ago
parent
commit
5d41ab021a
  1. 4
      aspnet-core/framework/common/LINGYUN.Abp.EventBus.CAP/LINGYUN/Abp/EventBus/CAP/AbpCAPBootstrapper.cs

4
aspnet-core/framework/common/LINGYUN.Abp.EventBus.CAP/LINGYUN/Abp/EventBus/CAP/AbpCAPBootstrapper.cs

@ -60,6 +60,7 @@ public class AbpCAPBootstrapper : IBootstrapper
foreach (var item in _processors) foreach (var item in _processors)
{
try try
{ {
item.Dispose(); item.Dispose();
@ -68,6 +69,7 @@ public class AbpCAPBootstrapper : IBootstrapper
{ {
_logger.LogWarning(ex, $"Expected an OperationCanceledException, but found '{ex.Message}'."); _logger.LogWarning(ex, $"Expected an OperationCanceledException, but found '{ex.Message}'.");
} }
}
}); });
await BootstrapCoreAsync().ConfigureAwait(false); await BootstrapCoreAsync().ConfigureAwait(false);
@ -84,7 +86,7 @@ public class AbpCAPBootstrapper : IBootstrapper
{ {
_cts!.Token.ThrowIfCancellationRequested(); _cts!.Token.ThrowIfCancellationRequested();
await item.Start(_cts!.Token); await item.StartAsync(_cts!.Token);
} }
catch (OperationCanceledException) catch (OperationCanceledException)
{ {

Loading…
Cancel
Save