def _connect(self): cp = pika.ConnectionParameters(host=self.host, port=self.port) self._conn = pika.BlockingConnection(cp)