diff --git a/queue.go b/queue.go index 429d776..7425f43 100644 --- a/queue.go +++ b/queue.go @@ -89,6 +89,7 @@ func (lq *LoafleQueue) Close() { if lq.eventChanel != nil { observer.Remove(lq.queueType, lq.eventChanel) } + lq.items = nil } func NewQueue(eventType string, interval time.Duration, senderChanel chan interface{}) *LoafleQueue { items := make([]*Item, 0)