Method: PerfectQueue::Multiprocess::ForkProcessor#restart

Defined in:
lib/perfectqueue/multiprocess/fork_processor.rb

#restart(immediate, config) ⇒ Object 



34
35
36
37
38
39
40
41
42
43
44
45
46
 
# File 'lib/perfectqueue/multiprocess/fork_processor.rb', line 34

def restart(immediate, config)
  @child_heartbeat_limit = config[:child_heartbeat_limit] || 60.0
  @child_kill_interval = config[:child_kill_interval] || 2.0
  @child_graceful_kill_limit = config[:child_graceful_kill_limit] || nil
  @child_fork_frequency_limit = config[:child_fork_frequency_limit] || 5.0
  @child_heartbeat_kill_delay = config[:child_heartbeat_kill_delay] || 10
  @log = config[:logger]
  @config = config  # for child process

  if c = @cpm
    c.start_killing(immediate)
  end
end