#NEWLINE# @ defer . inlineCallbacks #NEWLINE# def _process( self , channel , method , properties , body ) : #NEWLINE# #INDENT# try : #NEWLINE# #INDENT# ( yield self . process ( channel = channel , method = method , properties = properties , body = body ) ) #NEWLINE# #UNINDENT# except Exception as e : #NEWLINE# #INDENT# if self . log_processor_exceptions : #NEWLINE# #INDENT# log_func = getattr ( logger , self . log_processor_exceptions . lower ( ) ) #NEWLINE# log_func ( 'Exception raised during processing' , exc_info = True ) #NEWLINE# #UNINDENT# if self . no_ack : #NEWLINE# #INDENT# return #NEWLINE# #UNINDENT# if self . nack_after_failed_processing : #NEWLINE# #INDENT# ( yield channel . basic_reject ( delivery_tag = channel . delivery_tag ) ) #NEWLINE# #UNINDENT# if self . ack_after_failed_processing : #NEWLINE# #INDENT# ( yield channel . basic_ack ( delivery_tag = method . delivery_tag ) ) #NEWLINE# #UNINDENT# #UNINDENT# else : #NEWLINE# #INDENT# if ( ( not self . no_ack ) and self . ack_after_successful_processing ) : #NEWLINE# #INDENT# ( yield channel . basic_ack ( delivery_tag = method . delivery_tag ) )