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