|
|
|
@ -14,10 +14,10 @@ namespace Lion.AbpPro.CAP |
|
|
|
{ |
|
|
|
[Dependency(ServiceLifetime.Singleton, ReplaceServices = true)] |
|
|
|
[ExposeServices(typeof(IConsumerServiceSelector))] |
|
|
|
public class AbpProAbpCapConsumerServiceSelector : ConsumerServiceSelector |
|
|
|
public sealed class AbpProAbpCapConsumerServiceSelector : ConsumerServiceSelector |
|
|
|
{ |
|
|
|
protected AbpDistributedEventBusOptions AbpDistributedEventBusOptions { get; } |
|
|
|
protected IServiceProvider ServiceProvider { get; } |
|
|
|
private AbpDistributedEventBusOptions AbpDistributedEventBusOptions { get; } |
|
|
|
private IServiceProvider ServiceProvider { get; } |
|
|
|
|
|
|
|
/// <summary>
|
|
|
|
/// Creates a new <see cref="T:DotNetCore.CAP.Internal.ConsumerServiceSelector" />.
|
|
|
|
@ -73,7 +73,7 @@ namespace Lion.AbpPro.CAP |
|
|
|
return executorDescriptorList; |
|
|
|
} |
|
|
|
|
|
|
|
protected virtual IEnumerable<ConsumerExecutorDescriptor> GetHandlerDescription(Type eventType,Type typeInfo) |
|
|
|
private IEnumerable<ConsumerExecutorDescriptor> GetHandlerDescription(Type eventType,Type typeInfo) |
|
|
|
{ |
|
|
|
var serviceTypeInfo = typeof(IDistributedEventHandler<>) |
|
|
|
.MakeGenericType(eventType); |
|
|
|
|