fix exception propagation

ppossanzini · Jan 9, 2025 · e2ee495 · e2ee495
1 parent 1a2f2e0
commit e2ee495
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/Arbitrer.GRPC/RequestsManager.cs b/Arbitrer.GRPC/RequestsManager.cs
@@ -96,7 +96,7 @@ private async Task<string> ManageGenericArbitrerMessage<T>(RequestMessage reques
       }
       catch (Exception ex)
       {
-        responseMsg = JsonConvert.SerializeObject(new Messages.ResponseMessage { Exception = ex, Status = Messages.StatusEnum.Exception },
+        responseMsg = JsonConvert.SerializeObject(new Messages.ResponseMessage { Exception = ex, Status = Messages.StatusEnum.Exception ,Content = Unit.Value },
           _options.SerializerSettings);
         _logger.LogError(ex, $"Error executing message of type {typeof(T)} from external service");
       }

diff --git a/Arbitrer.Kafka/RequestsManager.cs b/Arbitrer.Kafka/RequestsManager.cs
@@ -189,7 +189,7 @@ private async Task ConsumeChannelMessage<T>(string msg)
         responseMsg = JsonConvert.SerializeObject(
           new KafkaReply()
           {
-            Reply = new Messages.ResponseMessage { Exception = ex, Status = Messages.StatusEnum.Exception },
+            Reply = new Messages.ResponseMessage { Exception = ex, Status = Messages.StatusEnum.Exception , Content = Unit.Value},
             CorrelationId = message.CorrelationId
           }
           , _options.SerializerSettings);