lib/backburner/workers/threading.rb in backburner-allq-1.0.19 vs lib/backburner/workers/threading.rb in backburner-allq-1.0.20
- old
+ new
@@ -56,10 +56,10 @@
pool.post(connection) do |memo_connection|
# TODO: use read-write lock?
loop do
begin
break if @in_shutdown
- work_one_job(memo_connection)
+ work_one_job(memo_connection, tube_name)
rescue => e
log_error("Exception caught in thread pool loop. Continuing. -> #{e.message}\nBacktrace: #{e.backtrace}")
end
end