#NEWLINE# def handle_message_processed( self , message , result = None , exc_info = None ) : #NEWLINE# #INDENT# if ( ( exc_info is not None ) and self . requeue_on_error ) : #NEWLINE# #INDENT# self . queue_consumer . requeue_message ( message ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# self . queue_consumer . ack_message ( message )