fix bug

b0dd2c62 · vicotor · 36c11520 · b0dd2c62
Commit b0dd2c62 authored Mar 19, 2024 by vicotor
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

node.go server/node.go +1 -1

No files found.
--- a/server/node.go
+++ b/server/node.go
@@ -353,7 +353,7 @@ func (c *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim saram
 }

 func (n *Node) addWorkerBack(w Worker) {
-	n.rdb.LPush(context.Background(), config.WORKER_QUEUE_PREFIX+strconv.Itoa(w.priority), workerId(w))
+	n.rdb.RPush(context.Background(), config.WORKER_QUEUE_PREFIX+strconv.Itoa(w.priority), workerId(w))
 	log.WithField("worker", w.workerid).Debug("add worker back to queue")
 }