runtime/WampClient.py
changeset 2309 d8fb90a2e11f
parent 2308 4d7cee25a474
child 2315 523559fe6352
equal deleted inserted replaced
2308:4d7cee25a474 2309:d8fb90a2e11f
   142         super(WampSession, self).onLeave(details)
   142         super(WampSession, self).onLeave(details)
   143         _WampSession = None
   143         _WampSession = None
   144         _transportFactory = None
   144         _transportFactory = None
   145         print(_('WAMP session left'))
   145         print(_('WAMP session left'))
   146 
   146 
   147     def publishWithOwnID(eventID, value):
   147     def publishWithOwnID(self, eventID, value):
   148         ID = self.config.extra["ID"]
   148         ID = self.config.extra["ID"]
   149         self.publish(unicode(ID+'.'+eventID), value)
   149         self.publish(unicode(ID+'.'+eventID), value)
       
   150 
   150 
   151 
   151 class ReconnectingWampWebSocketClientFactory(WampWebSocketClientFactory, ReconnectingClientFactory):
   152 class ReconnectingWampWebSocketClientFactory(WampWebSocketClientFactory, ReconnectingClientFactory):
   152 
   153 
   153     def __init__(self, config, *args, **kwargs):
   154     def __init__(self, config, *args, **kwargs):
   154         global _transportFactory
   155         global _transportFactory
   341 
   342 
   342 def SetServer(pysrv):
   343 def SetServer(pysrv):
   343     global _PySrv
   344     global _PySrv
   344     _PySrv = pysrv
   345     _PySrv = pysrv
   345 
   346 
       
   347 
   346 def PublishEvent(eventID, value):
   348 def PublishEvent(eventID, value):
   347     if getWampStatus() == "Attached":
   349     if getWampStatus() == "Attached":
   348          _WampSession.publish(eventID, value)
   350         _WampSession.publish(eventID, value)
       
   351 
   349 
   352 
   350 def PublishEventWithOwnID(eventID, value):
   353 def PublishEventWithOwnID(eventID, value):
   351     if getWampStatus() == "Attached":
   354     if getWampStatus() == "Attached":
   352          _WampSession.publishWithOwnID(eventID, value)
   355         _WampSession.publishWithOwnID(eventID, value)
       
   356 
   353 
   357 
   354 # WEB CONFIGURATION INTERFACE
   358 # WEB CONFIGURATION INTERFACE
   355 WAMP_SECRET_URL = "secret"
   359 WAMP_SECRET_URL = "secret"
   356 webExposedConfigItems = ['active', 'url', 'ID']
   360 webExposedConfigItems = ['active', 'url', 'ID']
   357 
   361