diff --git a/lib/sidekiq_unique_jobs/locksmith.rb b/lib/sidekiq_unique_jobs/locksmith.rb index 9c06969c..7c97a904 100644 --- a/lib/sidekiq_unique_jobs/locksmith.rb +++ b/lib/sidekiq_unique_jobs/locksmith.rb @@ -312,7 +312,7 @@ def brpoplpush(conn, wait) # @api private # def rpoplpush(conn) - conn.rpoplpush(key.queued, key.primed) + conn.lmove(key.queued, key.primed, "RIGHT", "LEFT") end # diff --git a/spec/support/sidekiq_unique_jobs/testing.rb b/spec/support/sidekiq_unique_jobs/testing.rb index 41c5c722..19f3d013 100644 --- a/spec/support/sidekiq_unique_jobs/testing.rb +++ b/spec/support/sidekiq_unique_jobs/testing.rb @@ -328,7 +328,7 @@ def rpop(key) end def rpoplpush(source, destination) - redis { |conn| conn.rpoplpush(source, destination) } + redis { |conn| conn.lmove(source, destination, "RIGHT", "LEFT") } end def blpop(*args)