parameters: (self, msgid, content)
docstring: when a message is received from the MQ
  
              WARNING : for core components :
              notice that this function is not called when the manager starts with -r, -d, -x options as the IOLoop is not yet started. This function is only used after manager startup
docstring_summary: when a message is received from the MQ
docstring_tokens: when a message is received from the MQ
function: def on_message(self, msgid, content):
          """ when a message is received from the MQ
  
              WARNING : for core components :
              notice that this function is not called when the manager starts with -r, -d, -x options as the IOLoop is not yet started. This function is only used after manager startup
          """
  
          # TODO : the below if seems useless as this is a core component and not a plugin !
          # to delete ?
          #pass
  
          #self.log.debug(u"Core : New pub message received {0}".format(msgid))
          #self.log.debug(u"{0}".format(content))
          if msgid == "plugin.status":
              if content["type"] == self.type and content["name"] == self.name and content["host"] == self.host:
                  self.log.debug(u"CoreComponent : New status received from {0} {1} on {2} => {3} {4}".format(self.type, self.name, self.host, content["event"], content["comment"]))
                  self.set_status(content["event"], content["comment"])
function_tokens: def on_message ( self , msgid , content ) : # TODO : the below if seems useless as this is a core component and not a plugin ! # to delete ? #pass #self.log.debug(u"Core : New pub message received {0}".format(msgid)) #self.log.debug(u"{0}".format(content)) if msgid == "plugin.status" : if content [ "type" ] == self . type and content [ "name" ] == self . name and content [ "host" ] == self . host : self . log . debug ( u"CoreComponent : New status received from {0} {1} on {2} => {3} {4}" . format ( self . type , self . name , self . host , content [ "event" ] , content [ "comment" ] ) ) self . set_status ( content [ "event" ] , content [ "comment" ] )