#NEWLINE# def do_ack( self , args ) : #NEWLINE# #INDENT# args = args . split ( ) #NEWLINE# hdrs = self . check_ack_nack ( 'ack' , args ) #NEWLINE# if ( hdrs is None ) : #NEWLINE# #INDENT# return #NEWLINE# #UNINDENT# ( message_id , subscription_id ) = hdrs #NEWLINE# if ( not message_id . transaction_id ) : #NEWLINE# #INDENT# self . conn . ack ( message_id , subscription_id ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# self . conn . ack ( message_id , subscription_id , transaction = self . transaction_id )