env = Attribute("env", "Environnement variable of the application")
stdin = Attribute("stdin", "Input of the application", default = "")
sources = Attribute("sources", "Sources of the application",
env = Attribute("env", "Environnement variable of the application")
stdin = Attribute("stdin", "Input of the application", default = "")
sources = Attribute("sources", "Sources of the application",
cls._register_attribute(appid)
cls._register_attribute(path)
cls._register_attribute(args)
cls._register_attribute(appid)
cls._register_attribute(path)
cls._register_attribute(args)
if rm_list: return rm_list[0]
return None
def stdin_hook(self, old_value, new_value):
if rm_list: return rm_list[0]
return None
def stdin_hook(self, old_value, new_value):
msg = ("Connection between %s %s and %s %s refused: "
"An Application can be connected only to a Node" ) % \
msg = ("Connection between %s %s and %s %s refused: "
"An Application can be connected only to a Node" ) % \
- (self.rtype(), self._guid, rm.rtype(), guid)
+ (self.get_rtype(), self._guid, rm.get_rtype(), guid)
elif len(self.connections) != 0 :
msg = ("Connection between %s %s and %s %s refused: "
"This Application is already connected" ) % \
elif len(self.connections) != 0 :
msg = ("Connection between %s %s and %s %s refused: "
"This Application is already connected" ) % \
- (self.rtype(), self._guid, rm.rtype(), guid)
+ (self.get_rtype(), self._guid, rm.get_rtype(), guid)
- self.rtype(), self._guid, rm.rtype(), guid)
+ self.get_rtype(), self._guid, rm.get_rtype(), guid)
self.set('xmppSlice',self.node.get('xmppSlice'))
self.set('xmppHost',self.node.get('xmppHost'))
self.set('xmppPort',self.node.get('xmppPort'))
self.set('xmppSlice',self.node.get('xmppSlice'))
self.set('xmppHost',self.node.get('xmppHost'))
self.set('xmppPort',self.node.get('xmppPort'))
- try:
- self._omf_api.execute(self.node.get('hostname'),self.get('appid'), \
- self.get('args'), self.get('path'), self.get('env'))
- except AttributeError:
- msg = "Credentials are not initialzed. XMPP Connections impossible"
- self.error(msg)
- raise
+ self._omf_api.execute(self.node.get('hostname'),self.get('appid'), \
+ self.get('args'), self.get('path'), self.get('env'))