code: def _handle_one_message(self):
          
          result = True
  
          requesttype = self.query_socket.recv()
  
          if requesttype == b"PUBLISH":
              self._handle_incoming_event()
          elif requesttype == b"QUERY":
              self._handle_event_query()
          elif (self.exit_message is not None
                and requesttype == self.exit_message):
              _logger.warn("Asked to quit through an exit message."
                           "I'm quitting...")
              self.query_socket.send(b'QUIT')
              result = False
          else:
              _logger.warn("Could not identify request type: %s", requesttype)
              self._handle_unknown_command()
  
          return result
docs: Handle one single incoming message on any socket.
  
          This is the inner loop of the main application loop.
  
          Returns True if further messages should be received, False otherwise
          (it should quit, that is).
  
          It is crucial that this class function always respond with a
          query_socket.sent() for every query_socket.recv() call. Otherwise,
          clients and/or server might be stuck in limbo.