Module: Hawking

Extended by:
Hawking
Included in:
Hawking
Defined in:
lib/hawking.rb

Defined Under Namespace

Classes: Queue

Constant Summary collapse

VERSION = 
"0.1"

Instance Method Summary collapse

Instance Method Details

#job(queue, &block) ⇒ Object 



35
36
37
38
 
# File 'lib/hawking.rb', line 35

def job(queue, &block)
  @@jobs ||= {}
  @@jobs[queue] = block
end

#jobs ⇒ Object 



40
41
42
 
# File 'lib/hawking.rb', line 40

def jobs
  @@jobs
end

#run ⇒ Object 



10
11
12
13
14
15
16
 
# File 'lib/hawking.rb', line 10

def run
  puts "Working #{@@jobs.size} jobs: [ #{@@jobs.keys.join(' ')} ]"

  server = TCPServer.open "127.0.0.1", 4481

  loop { work_jobs server }
end

#work_jobs(server) ⇒ Object 



18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
 
# File 'lib/hawking.rb', line 18

def work_jobs(server)
  Thread.start(server.accept) do |listener|
    job = JSON.parse listener.gets, symbolize_names: true

    puts "Working on #{job[:queue]} (#{job[:data]})"

    begin
      Timeout::timeout(120) do
        handler = @@jobs[job[:queue]]
        handler.call(job[:data])
      end
    rescue Timeout::Error
      raise "The job hit 120 seconds timeout"
    end
  end
end