Skip to content

Commit 76d14d6

Browse files
committed
Remove redundant call to remove the message from the env queue in requeueMessage
1 parent de891d6 commit 76d14d6

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

apps/webapp/app/v3/marqs/index.server.ts

+2-3
Original file line numberDiff line numberDiff line change
@@ -1716,14 +1716,13 @@ local messageId = ARGV[3]
17161716
local messageData = ARGV[4]
17171717
local messageScore = ARGV[5]
17181718
1719-
-- First remove the old message from the sorted sets
1719+
-- First remove the message from the old queue
17201720
redis.call('ZREM', oldQueueKey, messageId)
1721-
redis.call('ZREM', envQueueKey, messageId)
17221721
17231722
-- Write the new message data
17241723
redis.call('SET', messageKey, messageData)
17251724
1726-
-- Add the message to the queues with new score
1725+
-- Add the message to the new queue with a new score
17271726
redis.call('ZADD', queueKey, messageScore, messageId)
17281727
redis.call('ZADD', envQueueKey, messageScore, messageId)
17291728

0 commit comments

Comments
 (0)