diff --git a/node/consensus/data/data_clock_consensus_engine.go b/node/consensus/data/data_clock_consensus_engine.go
index 910c327..65afc91 100644
--- a/node/consensus/data/data_clock_consensus_engine.go
+++ b/node/consensus/data/data_clock_consensus_engine.go
@@ -315,9 +315,9 @@ func (e *DataClockConsensusEngine) Start() <-chan error {
 	go e.runInfoMessageHandler()
 
 	e.logger.Info("subscribing to pubsub messages")
-	e.pubSub.RegisterValidator(e.frameFilter, e.validateFrameMessage, false)
-	e.pubSub.RegisterValidator(e.txFilter, e.validateTxMessage, false)
-	e.pubSub.RegisterValidator(e.infoFilter, e.validateInfoMessage, false)
+	e.pubSub.RegisterValidator(e.frameFilter, e.validateFrameMessage, true)
+	e.pubSub.RegisterValidator(e.txFilter, e.validateTxMessage, true)
+	e.pubSub.RegisterValidator(e.infoFilter, e.validateInfoMessage, true)
 	e.pubSub.Subscribe(e.frameFilter, e.handleFrameMessage)
 	e.pubSub.Subscribe(e.txFilter, e.handleTxMessage)
 	e.pubSub.Subscribe(e.infoFilter, e.handleInfoMessage)