AMQP worker

[mokevnin]

Используется так:

def subscribes subscribe Handler, :exchange_name => "exch", :queue_name =>"queue", :bind => {:key => "exch.#"}, :prefetch => 100, :queue => {:durable => true}, :exchange => {:durable => true} subscribe Handler, :exchange_name => "batch.exch", :queue_name =>"batch.queue", :bind => {:key => "batch.exch.#"}, :prefetch => 1, :queue => {:durable => true}, :exchange => {:durable => true} end