lib/right_chimp/queue/ChimpQueue.rb in right_chimp-2.1.22.2 vs lib/right_chimp/queue/ChimpQueue.rb in right_chimp-2.1.24

- old
+ new

@@ -4,18 +4,19 @@ # chimp work queue # class ChimpQueue include Singleton - attr_accessor :delay, :retry_count, :max_threads, :group + attr_accessor :delay, :retry_count, :max_threads, :group, :processing def initialize @delay = 0 @retry_count = 0 @max_threads = 10 @workers_never_exit = true @threads = [] @semaphore = Mutex.new + @processing = {} self.reset! end # # Reset the queue and the :default group