code: def commit(self):
          
          self._tx_active = False
          return self._channel.rpc_request(specification.Tx.Commit())
docs: Commit the current transaction.
  
              Commit all messages published during the current transaction
              session to the remote server.
  
              A new transaction session starts as soon as the command has
              been executed.
  
          :return: