def METHOD_NAME(self):
    if self._check_alive():
        return
    else:
        self._clear()
    if not self._conn:
        self._conn = pika.BlockingConnection(pika.ConnectionParameters(host=self._host, port=self._port,
                                                                       virtual_host=self._vhost,
                                                                       credentials=self._credentials,
                                                                       **self._extra_args))
    if not self._channel:
        self._channel = self._conn.channel()
        self._channel.confirm_delivery()