Method: MQueue::Queue#process

Defined in:
lib/m_queue/queue.rb

#process(msg) ⇒ Object

self



101
102
103
104
105
106
107
108
109
110
111
 
# File 'lib/m_queue/queue.rb', line 101

def process(msg)
  reload!
  begin
    on_message(YAML.load(msg))
  rescue => e
    #logger.error  "\n#{ e.message } - (#{ e.class })\n" <<  
    #              "#{(e.backtrace or []).join("\n")}"
    puts "\n#{ e.message } - (#{ e.class })\n" << 
                  "#{(e.backtrace or []).join("\n")}"
  end
end