lib/qpush/server/worker.rb in qpush-0.1.2 vs lib/qpush/server/worker.rb in qpush-0.1.4
- old
+ new
@@ -54,9 +54,10 @@
#
def build_threads
@perform_threads.times { @workers << Perform.new }
@queue_threads.times { @workers << Queue.new }
@delay_threads.times { @workers << Delay.new }
+ @workers << Heartbeat.new
end
# Information about the start process
#
def start_message