81 # start logging to console |
81 # start logging to console |
82 # log.startLogging(sys.stdout) |
82 # log.startLogging(sys.stdout) |
83 |
83 |
84 # create a WAMP application session factory |
84 # create a WAMP application session factory |
85 component_config = types.ComponentConfig( |
85 component_config = types.ComponentConfig( |
86 realm=realm, |
86 realm=unicode(realm), |
87 extra={"ID": ID}) |
87 extra={"ID": ID}) |
88 session_factory = wamp.ApplicationSessionFactory( |
88 session_factory = wamp.ApplicationSessionFactory( |
89 config=component_config) |
89 config=component_config) |
90 session_factory.session = WampSession |
90 session_factory.session = WampSession |
91 |
91 |
92 # create a WAMP-over-WebSocket transport client factory |
92 # create a WAMP-over-WebSocket transport client factory |
93 transport_factory = WampWebSocketClientFactory( |
93 transport_factory = WampWebSocketClientFactory( |
94 session_factory, |
94 session_factory, |
95 url=url, |
95 url=url, |
96 serializers=[MsgPackSerializer()], |
96 serializers=[MsgPackSerializer()]) |
97 debug=False, |
|
98 debug_wamp=False) |
|
99 |
97 |
100 # start the client from a Twisted endpoint |
98 # start the client from a Twisted endpoint |
101 conn = connectWS(transport_factory) |
99 conn = connectWS(transport_factory) |
102 confnodesroot.logger.write(_("WAMP connecting to URL : %s\n") % url) |
100 confnodesroot.logger.write(_("WAMP connecting to URL : %s\n") % url) |
103 return conn |
101 return conn |
109 _WampConnection = RegisterWampClient() |
107 _WampConnection = RegisterWampClient() |
110 AddToDoBeforeQuit(reactor.stop) |
108 AddToDoBeforeQuit(reactor.stop) |
111 reactor.run(installSignalHandlers=False) |
109 reactor.run(installSignalHandlers=False) |
112 |
110 |
113 def WampSessionProcMapper(funcname): |
111 def WampSessionProcMapper(funcname): |
114 wampfuncname = '.'.join((ID, funcname)) |
112 wampfuncname = unicode('.'.join((ID, funcname))) |
115 |
113 |
116 def catcher_func(*args, **kwargs): |
114 def catcher_func(*args, **kwargs): |
117 if _WampSession is not None: |
115 if _WampSession is not None: |
118 try: |
116 try: |
119 return threads.blockingCallFromThread( |
117 return threads.blockingCallFromThread( |