protocol/connections/engine.go

@@ -754,7 +754,7 @@ func (e *engine) handlePeerMessage(hostname string, eventID string, context stri
 		// later on...we still want to ack the original send...(as some "malformed" messages
 		// may be future-ok)
 		if cm, err := model.DeserializeMessage(string(message)); err == nil {
-			if cm.Overlay > 1024 && cm.Overlay&0x7 == 0x7 {
+			if cm.IsStream() {
 				return
 			}
 		}