diff --git a/src/core/message.c b/src/core/message.c
index d7e80dee..c6759ce4 100644
--- a/src/core/message.c
+++ b/src/core/message.c
@@ -697,7 +697,8 @@ nni_msg_get_pub_pid(nni_msg *m)
 
 	pos = nni_msg_body(m);
 	NNI_GET16(pos, len);
-	if (len > nni_msg_remaining_len(m) - 2)
+	// assume a min pub packet here
+	if (len > nni_msg_len(m) - 3)
 		return 0;
 	else {
 		NNI_GET16(pos + len + 2, pid);