From 3359465fd19c360b406867bb90ff1c292e6578eb Mon Sep 17 00:00:00 2001 From: Ryan LeCompte Date: Tue, 7 Feb 2012 20:10:38 -0800 Subject: [PATCH] move removal to ensure clause --- lib/sidekiq/middleware.rb | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/lib/sidekiq/middleware.rb b/lib/sidekiq/middleware.rb index ac5186db..9495a7b4 100644 --- a/lib/sidekiq/middleware.rb +++ b/lib/sidekiq/middleware.rb @@ -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