code: def _consume_rpc_request(self, arguments, consumer_tag, exclusive, no_ack,
                               no_local, queue):
          
          consume_frame = specification.Basic.Consume(queue=queue,
                                                      consumer_tag=consumer_tag,
                                                      exclusive=exclusive,
                                                      no_local=no_local,
                                                      no_ack=no_ack,
                                                      arguments=arguments)
          return self._channel.rpc_request(consume_frame)
docs: Create a Consume Frame and execute a RPC request.
  
          :param str queue: Queue name
          :param str consumer_tag: Consumer tag
          :param bool no_local: Do not deliver own messages
          :param bool no_ack: No acknowledgement needed
          :param bool exclusive: Request exclusive access
          :param dict arguments: Consume key/value arguments
  
          :rtype: dict