mq = MQ.new
mq.prefetch(10)
mq.queue('name').subscribe(:ack => true) do |info, msg|
  process(msg)
  info.ack
end