class EventMachine::Synchrony::AMQP::Channel

def queue!(name, opts = {})
  queue = Queue.new(self, name, opts)
  register_queue(queue)
end