Class: Oujoke::InvoiceQueue::Processor

Inherits:

Object

• Object
• Oujoke::InvoiceQueue::Processor

Includes:

Helper

Defined in:

lib/queue/processor.rb

Class Method Summary

• .run_process(queue, &block) ⇒ Object

  Call process on selected queue.

Methods included from Helper

#graceful_death, #log, #logp

Class Method Details

.run_process(queue, &block) ⇒ Object

Call process on selected queue

# File 'lib/queue/processor.rb', line 7

def self.run_process(queue, &block)
  queue.subscribe(:ack => true) { |headers, payload|
    data = unserialize(payload)
    block.call(data)
    headers.ack
  }
end