code: def process_messages_loop(self):
          
          self.receiving_messages = True
          try:
              self.process_messages_loop_internal()
          except pika.exceptions.ConnectionClosed as ex:
              logging.error("Connection closed {}.".format(ex))
              raise
docs: Processes incoming WorkRequest messages one at a time via functions specified by add_command.