diff -r c02818d7e29f -r 7e61baa047f0 runtime/WampClient.py --- a/runtime/WampClient.py Mon Aug 14 22:30:41 2017 +0300 +++ b/runtime/WampClient.py Mon Aug 14 23:27:15 2017 +0300 @@ -51,6 +51,7 @@ DoOnJoin = [] + def GetCallee(name): """ Get Callee or Subscriber corresponding to '.' spearated object path """ global _PySrv @@ -59,6 +60,7 @@ while names: obj = getattr(obj, names.pop(0)) return obj + class WampSession(wamp.ApplicationSession): @inlineCallbacks @@ -81,6 +83,7 @@ _WampSession = None print 'WAMP session left' + class ReconnectingWampWebSocketClientFactory(WampWebSocketClientFactory, ReconnectingClientFactory): def clientConnectionFailed(self, connector, reason): print("WAMP Client connection failed .. retrying ..") @@ -89,11 +92,13 @@ print("WAMP Client connection lost .. retrying ..") self.retry(connector) + def LoadWampClientConf(wampconf): WSClientConf = json.load(open(wampconf)) return WSClientConf + def RegisterWampClient(wampconf): WSClientConf = LoadWampClientConf(wampconf) @@ -122,10 +127,12 @@ print "WAMP client connecting to :",WSClientConf["url"] return conn + def GetSession(): global _WampSession return _WampSession + def SetServer(pysrv): global _PySrv _PySrv = pysrv