'Re-establish connection to the AMQP server.'

def _reconnect(self):

    self.conn = self.connect(self.conn)
    self._prepare_spec(self.conn)
    self.chan = self.conn.default_channel
    self.needs_reconnect = False
