Merge pull request #12670 from abpframework/liangshiwei/rebus

Rebus: Fix the problem of calling Handler multiple times

framework/src/Volo.Abp.EventBus.Rebus/Volo/Abp/EventBus/Rebus/AbpRebusEventHandlerStep.cs

@@ -1,4 +1,5 @@
 using System;
+using System.Collections.Generic;
 using System.Linq;
 using System.Threading.Tasks;
 using Rebus.Messages;
@@ -14,9 +15,12 @@ public class AbpRebusEventHandlerStep : IIncomingStep
         var message = context.Load<Message>();
         var handlerInvokers = context.Load<HandlerInvokers>().ToList();
 
-        handlerInvokers.RemoveAll(x => x.Handler.GetType() == typeof(RebusDistributedEventHandlerAdapter<object>));
+        if (handlerInvokers.All(x => x.Handler is IRebusDistributedEventHandlerAdapter))
-        context.Save(new HandlerInvokers(message, handlerInvokers));
+        {
-
+            handlerInvokers = new List<HandlerInvoker> {handlerInvokers.Last()};
+            context.Save(new HandlerInvokers(message, handlerInvokers));
+        }
+        
         return next();
     }
 }

framework/src/Volo.Abp.EventBus.Rebus/Volo/Abp/EventBus/Rebus/IRebusDistributedEventHandlerAdapter.cs

@@ -0,0 +1,6 @@
+namespace Volo.Abp.EventBus.Rebus;
+
+public interface IRebusDistributedEventHandlerAdapter
+{
+    
+}

framework/src/Volo.Abp.EventBus.Rebus/Volo/Abp/EventBus/Rebus/RebusDistributedEventHandlerAdapter.cs

@@ -3,7 +3,7 @@ using Rebus.Handlers;
 
 namespace Volo.Abp.EventBus.Rebus;
 
-public class RebusDistributedEventHandlerAdapter<TEventData> : IHandleMessages<TEventData>
+public class RebusDistributedEventHandlerAdapter<TEventData> : IHandleMessages<TEventData> , IRebusDistributedEventHandlerAdapter
 {
     protected RebusDistributedEventBus RebusDistributedEventBus { get; }