--- 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