Update priority_queue.go

xmidt-org · Aug 3, 2024 · 313eda4 · 313eda4
1 parent 2d37db0
commit 313eda4
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/internal/wrphandlers/qos/priority_queue.go b/internal/wrphandlers/qos/priority_queue.go
@@ -175,7 +175,6 @@ func (pq *priorityQueue) Swap(i, j int) {
 }
 
 func (pq *priorityQueue) Push(x any) {
-	expires := time.Now()
 	msg := x.(wrp.Message)
 	pq.sizeBytes += int64(len(msg.Payload))
 
@@ -193,7 +192,7 @@ func (pq *priorityQueue) Push(x any) {
 
 	pq.queue = append(pq.queue, item{
 		msg:     &msg,
-		expires: expires.Add(qosExpires),
+		expires: time.Now().Add(qosExpires),
 		expired: false})
 }