diff --git a/node/consensus/master/master_clock_consensus_engine.go b/node/consensus/master/master_clock_consensus_engine.go
index da70de3..b17acdb 100644
--- a/node/consensus/master/master_clock_consensus_engine.go
+++ b/node/consensus/master/master_clock_consensus_engine.go
@@ -1,6 +1,7 @@
 package master
 
 import (
+	"bytes"
 	gcrypto "crypto"
 	"encoding/hex"
 	"math/big"
@@ -228,6 +229,10 @@ func (e *MasterClockConsensusEngine) Start() <-chan error {
 	}()
 
 	go func() {
+		if !bytes.Equal(e.pubSub.GetPeerID(), []byte(e.beacon)) {
+			return
+		}
+
 		for e.state < consensus.EngineStateStopping {
 			frame, err := e.masterTimeReel.Head()
 			if err != nil {