code: async def _on_message(self, update):
          
  
          name = update['service']
          message_obj = update['payload']
  
          if name not in self.services:
              return
  
          with self._state_lock:
              self.services[name].post_message(message_obj['level'], message_obj['message'])
docs: Receive a message from a service.