#NEWLINE# def _handle_request( self , callback , exchange , response ) : #NEWLINE# #INDENT# try : #NEWLINE# #INDENT# self . queue_len = ( self . queue_len - 1 ) #NEWLINE# if response . error : #NEWLINE# #INDENT# logging . error ( exchange . error ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# callback ( exchange , response . body ) #NEWLINE# #UNINDENT# #UNINDENT# except StandardError : #NEWLINE# #INDENT# logging . error ( 'Wrong data format.' ) #NEWLINE# #UNINDENT# finally : #NEWLINE# #INDENT# self . stop ( )