docs: def consume(self, consumer_callback, exclusive=False, recover=False):
  		"""
  		Initialize consuming of messages from an AMQP queue. Messages will be consumed after start_consuming() is called.
  
  		Calling this method multiple times with exclusive active will result in a pika.exceptions.ChannelClosed Error.
  
  		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?
  		recover: boolean
  			Asks the server to requeue all previously delivered but not acknowledged messages. This can be used to recover from a sudden
  			disconnect or other error.
  
  		Returns
  		-------
  		string
  			Returns a generated consumer_tag.
  		"""
  		if recover:
  			self.logger.info("Asking server to requeue all unacknowledged messages")
  			self.channel.basic_recover(requeue=True)
  		self.consumer_tag = self.channel.basic_consume(consumer_callback=consumer_callback, queue=self.queue_name, exclusive=exclusive)
  		return self.consumer_tag