Method: MQueue::Queue.run

Defined in:
lib/m_queue/queue.rb

.run ⇒ Object 



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

def run
  num_sleeps = 0
  loop do
    msg = poll
    self.new.process(msg) if msg
    if !msg
      if num_sleeps < 50
        num_sleeps += 1
        num_sleeps *= 2
      end
      sleep 2 #num_sleeps
    else
      num_sleeps = 0
    end
  end
end