equal
deleted
inserted
replaced
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 |