#NEWLINE# def start( self ) : #NEWLINE# #INDENT# if self . started : #NEWLINE# #INDENT# raise ValueError ( 'called stomp.Connection.start() twice' ) #NEWLINE# #UNINDENT# self . started = True #NEWLINE# ml . ld2 ( 'start Setting sock broken' ) #NEWLINE# self . sock_broken . set ( ) #NEWLINE# ml . ld2 ( 'start clearing sock ready' ) #NEWLINE# self . sock_ready . clear ( ) #NEWLINE# weak = weakref . proxy ( self , _killsock_later ( weak . sock_container ) ) #NEWLINE# self . send_glet = gevent . spawn ( _run_send , weak ) #NEWLINE# self . recv_glet = gevent . spawn ( _run_recv , weak ) #NEWLINE# self . sock_glet = gevent . spawn ( _run_socket_fixer , weak )