Module: Droonga::Worker

Defined in:
lib/droonga/worker.rb

Instance Method Summary collapse

Instance Method Details

#initialize ⇒ Object 



23
24
25
26
 
# File 'lib/droonga/worker.rb', line 23

def initialize
  @database_name = config[:database]
  @queue_name = config[:queue_name] || "DroongaQueue"
end

#run ⇒ Object 



28
29
30
31
32
33
34
35
36
37
38
39
 
# File 'lib/droonga/worker.rb', line 28

def run
  $log.trace("#{log_tag}: run: start")
  handler = Handler.new(config)
  job_queue = JobQueue.open(@database_name, @queue_name)
  @running = true
  while @running
    process(handler, job_queue)
  end
  handler.shutdown
  job_queue.close
  $log.trace("#{log_tag}: run: done")
end

#stop ⇒ Object 



41
42
43
44
45
 
# File 'lib/droonga/worker.rb', line 41

def stop
  $log.trace("#{log_tag}: stop: start")
  @running = false
  $log.trace("#{log_tag}: stop: done")
end