equal
deleted
inserted
replaced
136 Thread(target=ThreadProc).start() |
136 Thread(target=ThreadProc).start() |
137 else: |
137 else: |
138 _WampConnection = threads.blockingCallFromThread( |
138 _WampConnection = threads.blockingCallFromThread( |
139 reactor, RegisterWampClient) |
139 reactor, RegisterWampClient) |
140 if not _WampSessionEvent.wait(5): |
140 if not _WampSessionEvent.wait(5): |
141 _WampConnection = stopConnecting() |
141 _WampConnection.stopConnecting() |
142 raise Exception(_("WAMP connection timeout")) |
142 raise Exception(_("WAMP connection timeout")) |
143 |
143 |
144 def __del__(self): |
144 def __del__(self): |
145 _WampConnection.disconnect() |
145 _WampConnection.disconnect() |
146 # |
146 # |