Fix memory leaks

rabbitmq · Mar 4, 2023 · 2b75ce4 · 2b75ce4
1 parent 5656876
commit 2b75ce4
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/consumers.go b/consumers.go
@@ -75,6 +75,7 @@ func (subs *consumers) buffer(in chan *Delivery, out chan Delivery) {
 				}
 
 			case out <- *queue[0]:
+				queue[0] = nil // Make the memory recycle normally
 				queue = queue[1:]
 			}
 		}