Browse Source

make methods of local distributed eventbus virtual

pull/21664/head
Nico Lachmuth 2 years ago
parent
commit
630139052e
  1. 34
      framework/src/Volo.Abp.EventBus/Volo/Abp/EventBus/Distributed/LocalDistributedEventBus.cs

34
framework/src/Volo.Abp.EventBus/Volo/Abp/EventBus/Distributed/LocalDistributedEventBus.cs

@ -81,88 +81,88 @@ public class LocalDistributedEventBus : IDistributedEventBus, ISingletonDependen
return Subscribe(typeof(TEvent), handler); return Subscribe(typeof(TEvent), handler);
} }
public IDisposable Subscribe<TEvent>(Func<TEvent, Task> action) where TEvent : class public virtual IDisposable Subscribe<TEvent>(Func<TEvent, Task> action) where TEvent : class
{ {
return _localEventBus.Subscribe(action); return _localEventBus.Subscribe(action);
} }
public IDisposable Subscribe<TEvent>(ILocalEventHandler<TEvent> handler) where TEvent : class public virtual IDisposable Subscribe<TEvent>(ILocalEventHandler<TEvent> handler) where TEvent : class
{ {
return _localEventBus.Subscribe(handler); return _localEventBus.Subscribe(handler);
} }
public IDisposable Subscribe<TEvent, THandler>() where TEvent : class where THandler : IEventHandler, new() public virtual IDisposable Subscribe<TEvent, THandler>() where TEvent : class where THandler : IEventHandler, new()
{ {
return _localEventBus.Subscribe<TEvent, THandler>(); return _localEventBus.Subscribe<TEvent, THandler>();
} }
public IDisposable Subscribe(Type eventType, IEventHandler handler) public virtual IDisposable Subscribe(Type eventType, IEventHandler handler)
{ {
return _localEventBus.Subscribe(eventType, handler); return _localEventBus.Subscribe(eventType, handler);
} }
public IDisposable Subscribe<TEvent>(IEventHandlerFactory factory) where TEvent : class public virtual IDisposable Subscribe<TEvent>(IEventHandlerFactory factory) where TEvent : class
{ {
return _localEventBus.Subscribe<TEvent>(factory); return _localEventBus.Subscribe<TEvent>(factory);
} }
public IDisposable Subscribe(Type eventType, IEventHandlerFactory factory) public virtual IDisposable Subscribe(Type eventType, IEventHandlerFactory factory)
{ {
return _localEventBus.Subscribe(eventType, factory); return _localEventBus.Subscribe(eventType, factory);
} }
public void Unsubscribe<TEvent>(Func<TEvent, Task> action) where TEvent : class public virtual void Unsubscribe<TEvent>(Func<TEvent, Task> action) where TEvent : class
{ {
_localEventBus.Unsubscribe(action); _localEventBus.Unsubscribe(action);
} }
public void Unsubscribe<TEvent>(ILocalEventHandler<TEvent> handler) where TEvent : class public virtual void Unsubscribe<TEvent>(ILocalEventHandler<TEvent> handler) where TEvent : class
{ {
_localEventBus.Unsubscribe(handler); _localEventBus.Unsubscribe(handler);
} }
public void Unsubscribe(Type eventType, IEventHandler handler) public virtual void Unsubscribe(Type eventType, IEventHandler handler)
{ {
_localEventBus.Unsubscribe(eventType, handler); _localEventBus.Unsubscribe(eventType, handler);
} }
public void Unsubscribe<TEvent>(IEventHandlerFactory factory) where TEvent : class public virtual void Unsubscribe<TEvent>(IEventHandlerFactory factory) where TEvent : class
{ {
_localEventBus.Unsubscribe<TEvent>(factory); _localEventBus.Unsubscribe<TEvent>(factory);
} }
public void Unsubscribe(Type eventType, IEventHandlerFactory factory) public virtual void Unsubscribe(Type eventType, IEventHandlerFactory factory)
{ {
_localEventBus.Unsubscribe(eventType, factory); _localEventBus.Unsubscribe(eventType, factory);
} }
public void UnsubscribeAll<TEvent>() where TEvent : class public virtual void UnsubscribeAll<TEvent>() where TEvent : class
{ {
_localEventBus.UnsubscribeAll<TEvent>(); _localEventBus.UnsubscribeAll<TEvent>();
} }
public void UnsubscribeAll(Type eventType) public virtual void UnsubscribeAll(Type eventType)
{ {
_localEventBus.UnsubscribeAll(eventType); _localEventBus.UnsubscribeAll(eventType);
} }
public Task PublishAsync<TEvent>(TEvent eventData, bool onUnitOfWorkComplete = true) public virtual Task PublishAsync<TEvent>(TEvent eventData, bool onUnitOfWorkComplete = true)
where TEvent : class where TEvent : class
{ {
return _localEventBus.PublishAsync(eventData, onUnitOfWorkComplete); return _localEventBus.PublishAsync(eventData, onUnitOfWorkComplete);
} }
public Task PublishAsync(Type eventType, object eventData, bool onUnitOfWorkComplete = true) public virtual Task PublishAsync(Type eventType, object eventData, bool onUnitOfWorkComplete = true)
{ {
return _localEventBus.PublishAsync(eventType, eventData, onUnitOfWorkComplete); return _localEventBus.PublishAsync(eventType, eventData, onUnitOfWorkComplete);
} }
public Task PublishAsync<TEvent>(TEvent eventData, bool onUnitOfWorkComplete = true, bool useOutbox = true) where TEvent : class public virtual Task PublishAsync<TEvent>(TEvent eventData, bool onUnitOfWorkComplete = true, bool useOutbox = true) where TEvent : class
{ {
return _localEventBus.PublishAsync(eventData, onUnitOfWorkComplete); return _localEventBus.PublishAsync(eventData, onUnitOfWorkComplete);
} }
public Task PublishAsync(Type eventType, object eventData, bool onUnitOfWorkComplete = true, bool useOutbox = true) public virtual Task PublishAsync(Type eventType, object eventData, bool onUnitOfWorkComplete = true, bool useOutbox = true)
{ {
return _localEventBus.PublishAsync(eventType, eventData, onUnitOfWorkComplete); return _localEventBus.PublishAsync(eventType, eventData, onUnitOfWorkComplete);
} }

Loading…
Cancel
Save