diff --git a/src/BuildingBlocks/Messaging/RabbitMq/Consumer/MultiMessageRabbitMqMessageConsumer.cs b/src/BuildingBlocks/Messaging/RabbitMq/Consumer/MultiMessageRabbitMqMessageConsumer.cs
index 2f01f0c..ef5ccb9 100644
--- 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)