diff -r cf5ef4c0deff -r 9fd29e8b1393 connectors/WAMP/__init__.py --- a/connectors/WAMP/__init__.py Mon Oct 02 12:43:01 2017 +0300 +++ b/connectors/WAMP/__init__.py Mon Oct 02 13:19:06 2017 +0300 @@ -44,13 +44,13 @@ class WampSession(wamp.ApplicationSession): def onJoin(self, details): - global _WampSession, _WampSessionEvent + global _WampSession _WampSession = self _WampSessionEvent.set() print('WAMP session joined for :', self.config.extra["ID"]) def onLeave(self, details): - global _WampSession, _WampSessionEvent + global _WampSession _WampSessionEvent.clear() _WampSession = None print('WAMP session left') @@ -113,7 +113,6 @@ wampfuncname = '.'.join((ID, funcname)) def catcher_func(*args, **kwargs): - global _WampSession if _WampSession is not None: try: return threads.blockingCallFromThread( @@ -132,7 +131,7 @@ class WampPLCObjectProxy(object): def __init__(self): - global _WampSessionEvent, _WampConnection + global _WampConnection if not reactor.running: Thread(target=ThreadProc).start() else: @@ -143,7 +142,6 @@ raise Exception(_("WAMP connection timeout")) def __del__(self): - global _WampConnection _WampConnection.disconnect() # # reactor.stop()