mirror of
https://github.com/mperham/sidekiq.git
synced 2022-11-09 13:52:34 -05:00
move removal to ensure clause
This commit is contained in:
parent
7081cd1ce5
commit
3359465fd1
1 changed files with 2 additions and 1 deletions
|
@ -92,7 +92,8 @@ module Sidekiq
|
|||
|
||||
def call(worker, msg, queue)
|
||||
yield
|
||||
@redis.srem("queue:encoded:#{queue}", Base64.encode64(msg.to_json))
|
||||
ensure
|
||||
@redis.srem("queue:encoded:#{queue}", Base64.encode64(MultiJson.encode(msg)))
|
||||
end
|
||||
end
|
||||
end
|
||||
|
|
Loading…
Add table
Reference in a new issue