equal
deleted
inserted
replaced
25 |
25 |
26 from __future__ import print_function |
26 from __future__ import print_function |
27 import sys |
27 import sys |
28 import traceback |
28 import traceback |
29 import atexit |
29 import atexit |
|
30 from threading import Thread, Event |
|
31 |
30 from twisted.internet import reactor, threads |
32 from twisted.internet import reactor, threads |
31 from autobahn.twisted import wamp |
33 from autobahn.twisted import wamp |
32 from autobahn.twisted.websocket import WampWebSocketClientFactory, connectWS |
34 from autobahn.twisted.websocket import WampWebSocketClientFactory, connectWS |
33 from autobahn.wamp import types |
35 from autobahn.wamp import types |
34 from autobahn.wamp.exception import TransportLost |
36 from autobahn.wamp.exception import TransportLost |
35 from autobahn.wamp.serializer import MsgPackSerializer |
37 from autobahn.wamp.serializer import MsgPackSerializer |
36 from threading import Thread, Event |
38 |
37 |
39 |
38 _WampSession = None |
40 _WampSession = None |
39 _WampConnection = None |
41 _WampConnection = None |
40 _WampSessionEvent = Event() |
42 _WampSessionEvent = Event() |
41 |
43 |