fix

dominikus1993 · Jun 8, 2024 · e2af07d · e2af07d
1 parent 5913eba
commit e2af07d
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/BuildingBlocks/Messaging/RabbitMq/Consumer/MultiMessageRabbitMqMessageConsumer.cs b/src/BuildingBlocks/Messaging/RabbitMq/Consumer/MultiMessageRabbitMqMessageConsumer.cs
@@ -99,9 +99,9 @@ protected override async Task ExecuteAsync(CancellationToken stoppingToken)
                 }
 
                 var subscriber = serviceScope.ServiceProvider.GetRequiredService(type.Handler);
-                var handle = _methodInfos.GetOrAdd(type.Message,
-                    (messageType) =>
-                        typeof(IMessageSubscriber<>).MakeGenericType(messageType).GetMethod(nameof(IMessageSubscriber<IMessage>.Handle))!);
+                var handle = _methodInfos.GetOrAdd(subscriber.GetType(),
+                    (subscriberType) =>
+                        subscriberType.GetMethod(nameof(IMessageSubscriber<IMessage>.Handle))!);
 
                 var result = await (Task<Result<Unit>>)handle.Invoke(subscriber, [msg, ct])!;
                 if (!result.IsSuccess)