Making it more robust to "thaw" out topic routed messages from Outbox

JasperFx · Nov 7, 2024 · 6023948 · 6023948
1 parent 0e2613b
commit 6023948
Showing 1 changed file with 17 additions and 1 deletion.
diff --git a/src/Transports/RabbitMQ/Wolverine.RabbitMQ/Internal/RabbitMqSender.cs b/src/Transports/RabbitMQ/Wolverine.RabbitMQ/Internal/RabbitMqSender.cs
@@ -1,3 +1,4 @@
+using JasperFx.Core;
 using Microsoft.Extensions.Logging;
 using RabbitMQ.Client;
 using Wolverine.Configuration;
@@ -27,7 +28,22 @@ public RabbitMqSender(RabbitMqEndpoint endpoint, RabbitMqTransport transport,
         _exchangeName = new CachedString(endpoint.ExchangeName);
         _key = endpoint.RoutingKey();
 
-        _toRoutingKey = routingType == RoutingMode.Static ? _ => new CachedString(_key) : x => new CachedString(TopicRouting.DetermineTopicName(x));
+        _toRoutingKey = routingType == RoutingMode.Static ? _ => new CachedString(_key) : x =>
+        {
+            if (x.TopicName.IsEmpty() && x.Message == null)
+            {
+                try
+                {
+                    runtime.Pipeline.TryDeserializeEnvelope(x, out var _);
+                }
+                catch (Exception e)
+                {
+                    Logger.LogError(e, "Error trying to deserialize an envelope in order to determine the topic name");
+                }
+            }
+
+            return new CachedString(TopicRouting.DetermineTopicName(x));
+        };
 
         _mapper = endpoint.BuildMapper(runtime);
         _endpoint = endpoint;