docs: def consume(self, consumer_callback=None, exclusive=False):
  		"""
  		Initialize consuming of messages from an AMQP RPC queue. Messages will be consumed after start_consuming() is called.
  
  		An internal callback will be used to handle incoming RPC responses. Only responses that have been registered with register_response()
  		will be kept internally, all other responses will be dropped silently. Responses can be accessed by using get_response().
  
  		The internal callback will assume that the incoming RPC responses will have a correlation_id property set in the headers.
  
  		Additionally, if a general purpose queue was created on construction, the parameters to this function can be used to declare a callback
  		and options for that queue. A ValueError is raised when trying to set a general purpose callback, but no queue was declared during
  		construction.
  
  		In contrast to the Queue class, the recover parameter is missing from this implementation of consume(). We will always try to requeue
  		old messages.
  
  		Parameters
  		----------
  		consumer_callback: callback
  			Function to call when a message is consumed. The callback function will be called on each delivery,
  			and will receive three parameters:
  				* channel
  				* method_frame
  				* header_frame
  				* body
  		exclusive: boolean
  			Is this consumer supposed to be the exclusive consumer of the given queue?
  		"""
  		if not hasattr(self, "queue_name") and consumer_callback:
  			raise ValueError("Trying to set a callback, while no general purpose queue was declared.")
  
  		self.rpc_consumer_tag = self.channel.basic_consume(consumer_callback=self._rpc_response_callback, queue=self.rpc_queue_name, exclusive=False)
  
  		if consumer_callback:
  			super(Rpc, self).consume(consumer_callback, exclusive, True)