diff --git a/daemons/node/nats.go b/daemons/node/nats.go
index 8483570..2120433 100644
--- a/daemons/node/nats.go
+++ b/daemons/node/nats.go
@@ -42,6 +42,8 @@ func ListenNATS(n Node) {
 					for k := range s {
 						if ad.ID != k {
 							m[k] = s[k]
+						} else {
+							s[k].Stream.Close()
 						}
 					}
 					ps[p] = m