fix

dominikus1993 · Feb 21, 2024 · 1426e34 · 1426e34
1 parent 1de6bc6
commit 1426e34
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/src/BuildingBlocks/Messaging/RabbitMq/Consumer/RabbitMqMessageConsumer.cs b/src/BuildingBlocks/Messaging/RabbitMq/Consumer/RabbitMqMessageConsumer.cs
@@ -92,6 +92,7 @@ protected override async Task ExecuteAsync(CancellationToken stoppingToken)
                 if (!result.IsSuccess)
                 {
                     logger.LogCantProcessMessage(result.ErrorValue, info.Exchange, info.RoutingKey, info.Queue);
+                    activity?.RecordException(result.ErrorValue);
                     return _subscriptionConfiguration.AckStrategy;
                 }
 

diff --git a/src/Modules/Catalog/Core/Repository/IProductWriter.cs b/src/Modules/Catalog/Core/Repository/IProductWriter.cs
@@ -10,8 +10,10 @@ namespace Catalog.Core.Repository;
 public sealed partial class AddProductResult : OneOfBase<Unit, Exception>
 {
     public bool IsSuccess => IsT0;
+
+    private static readonly AddProductResult OkValue = new AddProductResult(Unit.Value);
 
-    public static AddProductResult Ok() => new AddProductResult(Unit.Value);
+    public static AddProductResult Ok() => OkValue;
     public static AddProductResult Error(Exception exception) => new AddProductResult(exception);
 }