Discard transport messages that do not contain basic fields

Abc-Arbitrage · Mar 10, 2020 · b75adc8 · b75adc8
1 parent 5b4be49
commit b75adc8
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/src/Abc.Zebus/Transport/ZmqTransport.cs b/src/Abc.Zebus/Transport/ZmqTransport.cs
@@ -242,6 +242,9 @@ private void DeserializeAndForwardTransportMessage(CodedInputStream inputStream)
             {
                 var transportMessage = inputStream.ReadTransportMessage();
 
+                if (!IsValidTransportMessage(transportMessage))
+                    return;
+
                 if (!IsFromCurrentEnvironment(transportMessage))
                     return;
 
@@ -266,6 +269,14 @@ private void DeserializeAndForwardTransportMessage(CodedInputStream inputStream)
             }
         }
 
+        private bool IsValidTransportMessage(TransportMessage transportMessage)
+        {
+            return transportMessage.Id.Value != default
+                   && transportMessage.Environment != default
+                   && transportMessage.MessageTypeId.FullName != default
+                   && transportMessage.Originator != default;
+        }
+
         private void OnEndOfStreamAck(TransportMessage transportMessage)
         {
             var senderId = transportMessage.Originator.SenderId;