diff --git a/Arbitrer.GRPC/RequestsManager.cs b/Arbitrer.GRPC/RequestsManager.cs index 1577fa2..852edb9 100644 --- a/Arbitrer.GRPC/RequestsManager.cs +++ b/Arbitrer.GRPC/RequestsManager.cs @@ -96,7 +96,7 @@ private async Task ManageGenericArbitrerMessage(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 index dd67acc..d4ca365 100644 --- a/Arbitrer.Kafka/RequestsManager.cs +++ b/Arbitrer.Kafka/RequestsManager.cs @@ -189,7 +189,7 @@ private async Task ConsumeChannelMessage(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);