97         conn = connectWS(transport_factory)

    97         conn = connectWS(transport_factory)

    98         confnodesroot.logger.write(_("WAMP connecting to URL : %s\n") % url)

    98         confnodesroot.logger.write(_("WAMP connecting to URL : %s\n") % url)

    99         return conn

    99         return conn

   100 

   100 

   101     AddToDoBeforeQuit = confnodesroot.AppFrame.AddToDoBeforeQuit

   101     AddToDoBeforeQuit = confnodesroot.AppFrame.AddToDoBeforeQuit

   102     def ThreadProc():

   103     def ThreadProc():

   103         global _WampConnection

   104         global _WampConnection

   104         _WampConnection = RegisterWampClient()

   105         _WampConnection = RegisterWampClient()

   105         AddToDoBeforeQuit(reactor.stop)

   106         AddToDoBeforeQuit(reactor.stop)

   106         reactor.run(installSignalHandlers=False)

   107         reactor.run(installSignalHandlers=False)

   107 

   108 

   108     def WampSessionProcMapper(funcname):

   109     def WampSessionProcMapper(funcname):

   109         wampfuncname = '.'.join((ID, funcname))

   110         wampfuncname = '.'.join((ID, funcname))

   110         def catcher_func(*args, **kwargs):

   112         def catcher_func(*args, **kwargs):

   111             global _WampSession

   113             global _WampSession

   112             if _WampSession is not None:

   114             if _WampSession is not None:

   113                 try:

   115                 try:

   114                     return threads.blockingCallFromThread(

   116                     return threads.blockingCallFromThread(