code: def _get_channel(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()
  
file_path: FATE/python/fate/arch/federation/backends/rabbitmq/_mq_channel.py
imports: import json
  import logging
  import pika
  from fate.arch.federation.message_queue import nretry
label_desc: Use image node_id 8 for calling the MQChannel obj's underlying member method code with example usage: obj._get_channel() without return types