We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 771d316 + 6df6c0c commit c5484d2Copy full SHA for c5484d2
src/scene_server/datacollection/datacollection/porter.go
@@ -269,7 +269,10 @@ func (p *chanPorter) subscribeLoop() error {
269
if nil != err {
270
return fmt.Errorf("subscribe channel failed, %v", err)
271
}
272
- defer subChan.Unsubscribe(p.channels...)
+ defer func() {
273
+ _ = subChan.Unsubscribe(p.channels...)
274
+ _ = subChan.Close()
275
+ }()
276
277
blog.Info("[data-collection][%s] subscribing channel %v from redis", p.name, p.channels)
278
defer blog.Info("[data-collection][%s] unsubscribe channel %v from redis", p.name, p.channels)
0 commit comments