code: def commit(self, transaction=None, headers=None, **keyword_headers):
          
          assert transaction is not None, "'transaction' is required"
          headers = utils.merge_headers([headers, keyword_headers])
          headers[HDR_TRANSACTION] = transaction
          self.send_frame(CMD_COMMIT, headers)
docs: Commit a transaction.
  
          :param str transaction: the identifier for the transaction
          :param dict headers: a map of any additional headers the broker requires
          :param keyword_headers: any additional headers the broker requires