code: def process_transport_command(self, header, message):
          
          if not isinstance(message, dict):
              return
  
          relevant = False
          if "host" in message:  # Filter by host
              if message["host"] != self.__hostid:
                  return
              relevant = True
          if "service" in message:  # Filter by service
              if message["service"] != self._service_class_name:
                  return
              relevant = True
          if not relevant:  # Ignore message unless at least one filter matches
              return
  
          if message.get("command"):
              self.log.info(
                  "Received command '%s' via transport layer", message["command"]
              )
              if message["command"] == "shutdown":
                  self.shutdown = True
          else:
              self.log.warning("Received invalid transport command message")
docs: Parse a command coming in through the transport command subscription