#NEWLINE# def on_consume_channel_close( self , channel , code , text ) : #NEWLINE# #INDENT# self . logger . debug ( ( 'Consume channel closed [%d - %s].' % ( code , text ) ) ) #NEWLINE# if ( code == 320 ) : #NEWLINE# #INDENT# raise socket . error #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# if self . _connection : #NEWLINE# #INDENT# self . _connection . add_timeout ( self . retry_delay , self . open_consume_channel )