1 22 package org.jboss.tm.recovery; 23 24 import java.nio.ByteBuffer ; 25 26 35 class TransactionCompletionLogger implements TxCompletionHandler 36 { 37 38 private BatchLog log; 39 40 47 TransactionCompletionLogger(BatchLog log) 48 { 49 this.log = log; 50 } 51 52 66 public void handleTxCompletion(long localTransactionId) 67 { 68 ByteBuffer buffer = LogRecord.createTxEndRecord(localTransactionId); 69 BatchWriter writer = log.getBatchWriter(); 70 writer.addBatch(buffer, log); 71 } 72 73 } 74 | Popular Tags |