lib/backburner/workers/threads_on_fork.rb in backburner-allq-1.0.33 vs lib/backburner/workers/threads_on_fork.rb in backburner-allq-1.0.34
- old
+ new
@@ -219,10 +219,10 @@
@watched_tube_name = name
# No op for allq
end
def on_reconnect(conn)
- watch_tube(@watching_tube, conn) if @watching_tube
+ watch_tube(@watched_tube_name, conn) if @watched_tube_name
end
# Exit with Kernel.exit! to avoid at_exit callbacks that should belongs to
# parent process
# We will use exitcode 99 that means the fork reached the garbage number