diff --git a/system/p2p/dht/p2p.go b/system/p2p/dht/p2p.go
index fe9578bb73..e414dce6d0 100644
--- a/system/p2p/dht/p2p.go
+++ b/system/p2p/dht/p2p.go
@@ -204,7 +204,7 @@ func (p *P2P) CloseP2P() {
 
 	protocol.ClearEventHandler()
 	if !p.isRestart() {
-		p.mgr.PubSub.Unsub(p.subChan)
+		p.mgr.PubSub.Shutdown()
 
 	}
 	p.host.Close()