connectors/WAMP/__init__.py
changeset 1740 b789b695b5c6
parent 1739 ec153828ded2
child 1744 69dfdb26f600
--- a/connectors/WAMP/__init__.py	Tue Aug 15 12:17:51 2017 +0300
+++ b/connectors/WAMP/__init__.py	Tue Aug 15 15:50:30 2017 +0300
@@ -65,8 +65,8 @@
     """
     servicetype, location = uri.split("://")
     urlpath, realm, ID = location.split('#')
-    urlprefix = {"WAMP":"ws",
-                 "WAMPS":"wss"}[servicetype]
+    urlprefix = {"WAMP":  "ws",
+                 "WAMPS": "wss"}[servicetype]
     url = urlprefix+"://"+urlpath
 
     def RegisterWampClient():
@@ -77,7 +77,7 @@
         # create a WAMP application session factory
         component_config = types.ComponentConfig(
             realm = realm,
-            extra = {"ID":ID})
+            extra = {"ID": ID})
         session_factory = wamp.ApplicationSessionFactory(
             config = component_config)
         session_factory.session = WampSession
@@ -103,18 +103,18 @@
         reactor.run(installSignalHandlers=False)
 
     def WampSessionProcMapper(funcname):
-        wampfuncname = '.'.join((ID,funcname))
-        def catcher_func(*args,**kwargs):
+        wampfuncname = '.'.join((ID, funcname))
+        def catcher_func(*args, **kwargs):
             global _WampSession
             if _WampSession is not None:
                 try:
                     return threads.blockingCallFromThread(
                         reactor, _WampSession.call, wampfuncname,
-                        *args,**kwargs)
+                        *args, **kwargs)
                 except TransportLost, e:
                     confnodesroot.logger.write_error(_("Connection lost!\n"))
                     confnodesroot._SetConnector(None)
-                except Exception,e:
+                except Exception, e:
                     errmess = traceback.format_exc()
                     confnodesroot.logger.write_error(errmess+"\n")
                     print errmess