diff --git a/common/collect/timed_queue.go b/common/collect/timed_queue.go index 61791d86..5b619a86 100644 --- a/common/collect/timed_queue.go +++ b/common/collect/timed_queue.go @@ -73,7 +73,7 @@ func (queue *TimedQueue) Add(value interface{}, time2Remove int64) { } queue.access.Unlock() if removedEntry != nil { - queue.removedCallback(removedEntry) + queue.removedCallback(removedEntry.value) } }