diff --git a/p2p/base_reactor.go b/p2p/base_reactor.go
index 14025b590..cac9054f2 100644
--- a/p2p/base_reactor.go
+++ b/p2p/base_reactor.go
@@ -45,6 +45,8 @@ type Reactor interface {
 	//
 	// CONTRACT: msgBytes are not nil.
 	Receive(chID byte, peer Peer, msgBytes []byte)
+
+	NewReceive(Envelope)
 }
 
 //--------------------------------------
diff --git a/p2p/peer.go b/p2p/peer.go
index 081e22283..c7db24893 100644
--- a/p2p/peer.go
+++ b/p2p/peer.go
@@ -414,6 +414,10 @@ func createMConnection(
 		}
 		p.metrics.PeerReceiveBytesTotal.With(labels...).Add(float64(len(msgBytes)))
 		reactor.Receive(chID, p, msgBytes)
+		reactor.NewReceive(Envelope{
+			ChannelID: chID,
+			Src:       p,
+		})
 	}
 
 	onError := func(r interface{}) {