Don't check message definition matching

adnanademovic · May 13, 2017 · 89eb3d6 · 89eb3d6
1 parent 076509e
commit 89eb3d6
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/tcpros/publisher.rs b/src/tcpros/publisher.rs
@@ -21,8 +21,10 @@ fn read_request<T: Message, U: std::io::Read>(mut stream: &mut U, topic: &str) -
     let fields = header::decode(&mut stream)?;
     header::match_field(&fields, "md5sum", &T::md5sum())?;
     header::match_field(&fields, "type", &T::msg_type())?;
-    header::match_field(&fields, "message_definition", &T::msg_definition())?;
     header::match_field(&fields, "topic", topic)?;
+    if fields.get("message_definition").is_none() {
+        bail!(ErrorKind::HeaderMissingField("message_definition".into()));
+    }
     if fields.get("callerid").is_none() {
         bail!(ErrorKind::HeaderMissingField("callerid".into()));
     }