diff --git a/chain/messagepool/check.go b/chain/messagepool/check.go
index 8d6463691..84d2b3a11 100644
--- a/chain/messagepool/check.go
+++ b/chain/messagepool/check.go
@@ -243,7 +243,7 @@ func (mp *MessagePool) checkMessages(msgs []*types.Message, interned bool, flexi
 			},
 		}
 
-		if len(bytes) > 32*1024-128 { // 128 bytes to account for signature size
+		if len(bytes) > MaxMessageSize-128 { // 128 bytes to account for signature size
 			check.OK = false
 			check.Err = "message too big"
 		} else {
diff --git a/chain/sub/incoming.go b/chain/sub/incoming.go
index 7744fe1b9..ab2d198be 100644
--- a/chain/sub/incoming.go
+++ b/chain/sub/incoming.go
@@ -557,7 +557,7 @@ func (mv *MessageValidator) validateLocalMessage(ctx context.Context, msg *pubsu
 		return pubsub.ValidationIgnore
 	}
 
-	if m.Size() > 32*1024 {
+	if m.Size() > messagepool.MaxMessageSize {
 		log.Warnf("local message is too large! (%dB)", m.Size())
 		recordFailure(ctx, metrics.MessageValidationFailure, "oversize")
 		return pubsub.ValidationIgnore