From a5a55830b63556468d824346ecff808098e7667d Mon Sep 17 00:00:00 2001 From: liangshiwei Date: Wed, 28 Jul 2021 12:00:42 +0800 Subject: [PATCH] Remove IJsonSerializer use in LocalEventBus --- .../Volo/Abp/EventBus/Local/LocalEventBus.cs | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) diff --git a/framework/src/Volo.Abp.EventBus/Volo/Abp/EventBus/Local/LocalEventBus.cs b/framework/src/Volo.Abp.EventBus/Volo/Abp/EventBus/Local/LocalEventBus.cs index 16246a892f..3dc6045250 100644 --- a/framework/src/Volo.Abp.EventBus/Volo/Abp/EventBus/Local/LocalEventBus.cs +++ b/framework/src/Volo.Abp.EventBus/Volo/Abp/EventBus/Local/LocalEventBus.cs @@ -30,17 +30,13 @@ namespace Volo.Abp.EventBus.Local protected ConcurrentDictionary> HandlerFactories { get; } - protected IJsonSerializer Serializer { get; } - public LocalEventBus( IOptions options, IServiceScopeFactory serviceScopeFactory, ICurrentTenant currentTenant, - IEventErrorHandler errorHandler, - IJsonSerializer serializer) + IEventErrorHandler errorHandler) : base(serviceScopeFactory, currentTenant, errorHandler) { - Serializer = serializer; Options = options.Value; Logger = NullLogger.Instance; @@ -131,10 +127,9 @@ namespace Volo.Abp.EventBus.Local public virtual async Task PublishAsync(LocalEventMessage localEventMessage) { - var rawEventData = Serializer.Serialize(localEventMessage.EventData); await TriggerHandlersAsync(localEventMessage.EventType, localEventMessage.EventData, errorContext => { - errorContext.EventData = Serializer.Deserialize(localEventMessage.EventType, rawEventData); + errorContext.EventData = localEventMessage.EventData; errorContext.SetProperty(nameof(LocalEventMessage.MessageId), localEventMessage.MessageId); }); }