Change of state Conn Management
This commit is contained in:
@@ -42,6 +42,8 @@ func ListenNATS(n Node) {
|
|||||||
for k := range s {
|
for k := range s {
|
||||||
if ad.ID != k {
|
if ad.ID != k {
|
||||||
m[k] = s[k]
|
m[k] = s[k]
|
||||||
|
} else {
|
||||||
|
s[k].Stream.Close()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
ps[p] = m
|
ps[p] = m
|
||||||
|
|||||||
Reference in New Issue
Block a user