CompletableFuture < PingTxnStatus > pingTxnBody ( final String scope , final String stream , final UUID txnId , final long lease , final OperationContext ctx ) { if ( ! timeoutService . isRunning ( ) ) { return CompletableFuture . completedFuture ( createStatus ( Status . DISCONNECTED ) ) ; } log . debug ( "Txn={}, updating txn node in store and extending lease" , txnId ) ; return fenceTxnUpdateLease ( scope , stream , txnId , lease , ctx ) ; }
Ping a txn thereby updating its timeout to current time + lease .