fixed queue group memory leak

This commit is contained in:
Andrey Shalamov
2021-09-13 15:22:05 +03:00
parent b3c19b9dd1
commit 8575b334a2

View File

@@ -345,7 +345,7 @@ func (s *Sublist) chkForRemoveNotification(subject, queue string) {
}
// Move from the remove map to the insert map.
s.notify.insert[key] = append(s.notify.insert[key], chs...)
delete(s.notify.remove, subject)
delete(s.notify.remove, key)
}
}
}