diff --git a/Changes.md b/Changes.md index d70eb800..aefcb5cc 100644 --- a/Changes.md +++ b/Changes.md @@ -1,6 +1,12 @@ HEAD ----------- +- Fix fetch breaking retry when used with Redis namespaces. [#109] + + +0.11.0 +----------- + - Client-side API changes, added sidekiq\_options for Sidekiq::Worker. As a side effect of this change, the client API works on Ruby 1.8. It's not officially supported but should work [#103] diff --git a/lib/sidekiq/fetch.rb b/lib/sidekiq/fetch.rb index 329443d1..f711572a 100644 --- a/lib/sidekiq/fetch.rb +++ b/lib/sidekiq/fetch.rb @@ -35,7 +35,7 @@ module Sidekiq Sidekiq.redis { |conn| (queue, msg) = conn.blpop(*@cmd) } if msg - @mgr.assign!(msg, queue.gsub(/\Aqueue:/, '')) + @mgr.assign!(msg, queue.gsub(/.*queue:/, '')) else after(0) { fetch } end