#NEWLINE# def _connect( self , on_open_cb = None ) : #NEWLINE# #INDENT# self . log . info ( 'Beginning TornadoQueueClient connection' ) #NEWLINE# if self : #NEWLINE# #INDENT# self . _on_open_cbs . append ( on_open_cb ) #NEWLINE# #UNINDENT# self . connection = ExceptionFreeTornadoConnection ( self . _get_parameters ( ) , on_open_callback = self . _on_open , stop_ioloop_on_close = False ) #NEWLINE# self . connection . add_on_close_callback ( self . _on_connection_closed )