Reduce the SchemaMessageValidatorMiddleware only to two mandatory che…

…cks: Source and CorrelationId (#175)

* check against StreamId header has been removed as it is used only in Kafka contex

* check against Source header has been removed as it is not mandatory

* reduce the SchemaMessageValidatorMiddleware only to two mandatory checks

src/Messaging/NBB.Messaging.Host/MessagingPipeline/SchemaMessageValidatorMiddleware.cs

@@ -19,21 +19,9 @@ public class SchemaMessageValidatorMiddleware : IPipelineMiddleware<MessagingCon
     {
         public async Task Invoke(MessagingContext context, CancellationToken cancellationToken, Func<Task> next)
         {
-            if (!context.MessagingEnvelope.Headers.TryGetValue(MessagingHeaders.MessageType, out var _))
-                throw new Exception($"Message of type {context.MessagingEnvelope.Payload.GetType().GetPrettyName()} does not contain {MessagingHeaders.MessageType} header.");
-
             if (!context.MessagingEnvelope.Headers.TryGetValue(MessagingHeaders.CorrelationId, out var _))
                 throw new Exception($"Message of type {context.MessagingEnvelope.Payload.GetType().GetPrettyName()} does not contain {MessagingHeaders.CorrelationId} header.");
 
-            if (!context.MessagingEnvelope.Headers.TryGetValue(MessagingHeaders.MessageId, out var _))
-                throw new Exception($"Message of type {context.MessagingEnvelope.Payload.GetType().GetPrettyName()} does not contain {MessagingHeaders.MessageId} header.");
-
-            if (!context.MessagingEnvelope.Headers.TryGetValue(MessagingHeaders.PublishTime, out var _))
-                throw new Exception($"Message of type {context.MessagingEnvelope.Payload.GetType().GetPrettyName()} does not contain {MessagingHeaders.PublishTime} header.");
-
-            if (!context.MessagingEnvelope.Headers.TryGetValue(MessagingHeaders.StreamId, out var _))
-                throw new Exception($"Message of type {context.MessagingEnvelope.Payload.GetType().GetPrettyName()} does not contain {MessagingHeaders.StreamId} header.");
-
             if (!context.MessagingEnvelope.Headers.TryGetValue(MessagingHeaders.Source, out var _))
                 throw new Exception($"Message of type {context.MessagingEnvelope.Payload.GetType().GetPrettyName()} does not contain {MessagingHeaders.Source} header.");