diff --git a/node/consensus/data/message_validators.go b/node/consensus/data/message_validators.go
index cdf6810..1b13a42 100644
--- a/node/consensus/data/message_validators.go
+++ b/node/consensus/data/message_validators.go
@@ -88,6 +88,7 @@ func (e *DataClockConsensusEngine) validateTxMessage(peerID peer.ID, message *pb
 			e.stagedTransactionsSet[id] = struct{}{}
 			e.stagedTransactionsMx.Unlock()
 			if ok {
+				e.pubSub.AddPeerScore([]byte(peerID), -1000000)
 				return p2p.ValidationResultReject
 			}
 			if frameNumber+2 < head.FrameNumber {