diff --git a/src/NetMQ/Core/SessionBase.cs b/src/NetMQ/Core/SessionBase.cs index e7dbeddb..50835349 100644 --- a/src/NetMQ/Core/SessionBase.cs +++ b/src/NetMQ/Core/SessionBase.cs @@ -217,7 +217,7 @@ public void AttachPipe(Pipe pipe) /// true if the Msg is successfully sent public virtual PullMsgResult PullMsg(ref Msg msg) { - if (m_pipe == null || !m_pipe.Read(ref msg)) + if (m_pipe == null || !m_pipe.Read(ref msg) || !msg.IsInitialised) return PullMsgResult.Empty; m_incompleteIn = msg.HasMore;