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