class EventMachine::Synchrony::AMQP::Consumer

def resubscribe
  EM::Synchrony::AMQP.sync { |f| self.aconsume(&EM::Synchrony::AMQP.sync_cb(f)) }
  self
end