本文整理了Java中org.objectweb.howl.log.xa.XACommittingTx.getRecord()方法的一些代码示例，展示了XACommittingTx.getRecord()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。XACommittingTx.getRecord()方法的具体详情如下：
包路径：org.objectweb.howl.log.xa.XACommittingTx
类名称：XACommittingTx
方法名：getRecord

XACommittingTx.getRecord介绍

[英]returns the byte[][] containing the COMMIT record data.

This method is used by the log overflow notification processor to retrieve the original record data and write a new copy of the COMMIT record.
[中]返回包含提交记录数据的字节[]。
日志溢出通知处理器使用此方法检索原始记录数据并写入提交记录的新副本。

代码示例

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.howl

/**
 * displays entries in the activeTx table.
 * <p>useful for debug.
 */
public void activeTxDisplay()
{
 for (int i=0; i < activeTx.length; ++i)
 {
  if (activeTx[i] == null) continue;
  synchronized(activeTx)
  {
   XACommittingTx tx = activeTx[i];
   byte[][] record = tx.getRecord();
   System.out.println("activeTx[" + i + "] key=" + Long.toHexString(tx.getLogKey()) +
     "\n  Fields: " + record.length 
     );
   for (int j = 0; j < record.length; ++j)
   {
    byte[] field = record[j];
    System.out.println("  [" + j + "] len=" + field.length + ": " + new String(field));
   }
  }
 }
}

代码示例来源：origin: apache/felix

/**
 * displays entries in the activeTx table.
 * <p>useful for debug.
 */
public void activeTxDisplay()
{
 for (int i=0; i < activeTx.length; ++i)
 {
  if (activeTx[i] == null) continue;
  synchronized(activeTx)
  {
   XACommittingTx tx = activeTx[i];
   byte[][] record = tx.getRecord();
   System.out.println("activeTx[" + i + "] key=" + Long.toHexString(tx.getLogKey()) +
     "\n  Fields: " + record.length 
     );
   for (int j = 0; j < record.length; ++j)
   {
    byte[] field = record[j];
    System.out.println("  [" + j + "] len=" + field.length + ": " + new String(field));
   }
  }
 }
}

代码示例来源：origin: org.apache.servicemix.transaction/org.apache.servicemix.transaction

/**
 * displays entries in the activeTx table.
 * <p>useful for debug.
 */
public void activeTxDisplay()
{
 for (int i=0; i < activeTx.length; ++i)
 {
  if (activeTx[i] == null) continue;
  synchronized(activeTx)
  {
   XACommittingTx tx = activeTx[i];
   byte[][] record = tx.getRecord();
   System.out.println("activeTx[" + i + "] key=" + Long.toHexString(tx.getLogKey()) +
     "\n  Fields: " + record.length 
     );
   for (int j = 0; j < record.length; ++j)
   {
    byte[] field = record[j];
    System.out.println("  [" + j + "] len=" + field.length + ": " + new String(field));
   }
  }
 }
}

代码示例来源：origin: apache/felix

public void onRecord(LogRecord plainlr) {
  XALogRecord lr = (XALogRecord) plainlr;
  short recordType = lr.type;
  XACommittingTx tx = lr.getTx();
  if (recordType == LogRecordType.XACOMMIT) {
    byte[][] data = tx.getRecord();
    assert data[0].length == 4;
    int formatId = bytesToInt(data[1]);
    byte[] globalId = data[1];
    byte[] branchId = data[2];
    Xid masterXid = xidFactory.recover(formatId, globalId, branchId);
    Recovery.XidBranchesPair xidBranchesPair = new Recovery.XidBranchesPair(masterXid, tx);
    recoveredTx.put(masterXid, xidBranchesPair);
    log.debug("recovered prepare record for master xid: " + masterXid);
    for (int i = 3; i < data.length; i += 2) {
      byte[] branchBranchId = data[i];
      String name = new String(data[i + 1]);
      Xid branchXid = xidFactory.recover(formatId, globalId, branchBranchId);
      TransactionBranchInfoImpl branchInfo = new TransactionBranchInfoImpl(branchXid, name);
      xidBranchesPair.addBranch(branchInfo);
      log.debug("recovered branch for resource manager, branchId " + name + ", " + branchXid);
    }
  } else {
    if(recordType != LogRecordType.END_OF_LOG) { // This value crops up every time the server is started
      log.warn("Received unexpected log record: " + lr +" ("+recordType+")");
    }
  }
}

代码示例来源：origin: org.apache.servicemix.transaction/org.apache.servicemix.transaction

public void onRecord(LogRecord plainlr) {
  XALogRecord lr = (XALogRecord) plainlr;
  short recordType = lr.type;
  XACommittingTx tx = lr.getTx();
  if (recordType == LogRecordType.XACOMMIT) {
    byte[][] data = tx.getRecord();
    assert data[0].length == 4;
    int formatId = bytesToInt(data[1]);
    byte[] globalId = data[1];
    byte[] branchId = data[2];
    Xid masterXid = xidFactory.recover(formatId, globalId, branchId);
    Recovery.XidBranchesPair xidBranchesPair = new Recovery.XidBranchesPair(masterXid, tx);
    recoveredTx.put(masterXid, xidBranchesPair);
    log.debug("recovered prepare record for master xid: " + masterXid);
    for (int i = 3; i < data.length; i += 2) {
      byte[] branchBranchId = data[i];
      String name = new String(data[i + 1]);
      Xid branchXid = xidFactory.recover(formatId, globalId, branchBranchId);
      TransactionBranchInfoImpl branchInfo = new TransactionBranchInfoImpl(branchXid, name);
      xidBranchesPair.addBranch(branchInfo);
      log.debug("recovered branch for resource manager, branchId " + name + ", " + branchXid);
    }
  } else {
    if(recordType != LogRecordType.END_OF_LOG) { // This value crops up every time the server is started
      log.warn("Received unexpected log record: " + lr +" ("+recordType+")");
    }
  }
}

代码示例来源：origin: org.apache.geronimo.components/geronimo-transaction

public void onRecord(LogRecord plainlr) {
  XALogRecord lr = (XALogRecord) plainlr;
  short recordType = lr.type;
  XACommittingTx tx = lr.getTx();
  if (recordType == LogRecordType.XACOMMIT) {
    byte[][] data = tx.getRecord();
    assert data[0].length == 4;
    int formatId = bytesToInt(data[1]);
    byte[] globalId = data[1];
    byte[] branchId = data[2];
    Xid masterXid = xidFactory.recover(formatId, globalId, branchId);
    Recovery.XidBranchesPair xidBranchesPair = new Recovery.XidBranchesPair(masterXid, tx);
    recoveredTx.put(masterXid, xidBranchesPair);
    log.debug("recovered prepare record for master xid: " + masterXid);
    for (int i = 3; i < data.length; i += 2) {
      byte[] branchBranchId = data[i];
      String name = new String(data[i + 1]);
      Xid branchXid = xidFactory.recover(formatId, globalId, branchBranchId);
      TransactionBranchInfoImpl branchInfo = new TransactionBranchInfoImpl(branchXid, name);
      xidBranchesPair.addBranch(branchInfo);
      log.debug("recovered branch for resource manager, branchId " + name + ", " + branchXid);
    }
  } else {
    if(recordType != LogRecordType.END_OF_LOG) { // This value crops up every time the server is started
      log.warn("Received unexpected log record: " + lr +" ("+recordType+")");
    }
  }
}

代码示例来源：origin: org.apache.geronimo/com.springsource.org.apache.geronimo.transaction

public void onRecord(LogRecord plainlr) {
  XALogRecord lr = (XALogRecord) plainlr;
  short recordType = lr.type;
  XACommittingTx tx = lr.getTx();
  if (recordType == LogRecordType.XACOMMIT) {
    byte[][] data = tx.getRecord();
    assert data[0].length == 4;
    int formatId = bytesToInt(data[1]);
    byte[] globalId = data[1];
    byte[] branchId = data[2];
    Xid masterXid = xidFactory.recover(formatId, globalId, branchId);
    Recovery.XidBranchesPair xidBranchesPair = new Recovery.XidBranchesPair(masterXid, tx);
    recoveredTx.put(masterXid, xidBranchesPair);
    log.debug("recovered prepare record for master xid: " + masterXid);
    for (int i = 3; i < data.length; i += 2) {
      byte[] branchBranchId = data[i];
      String name = new String(data[i + 1]);
      Xid branchXid = xidFactory.recover(formatId, globalId, branchBranchId);
      TransactionBranchInfoImpl branchInfo = new TransactionBranchInfoImpl(branchXid, name);
      xidBranchesPair.addBranch(branchInfo);
      log.debug("recovered branch for resource manager, branchId " + name + ", " + branchXid);
    }
  } else {
    if(recordType != LogRecordType.END_OF_LOG) { // This value crops up every time the server is started
      log.warn("Received unexpected log record: " + lr +" ("+recordType+")");
    }
  }
}

代码示例来源：origin: apache/felix

byte[][] record = tx.getRecord();
short recordSize = 0;
for(int j=0; j < record.length; ++j)

代码示例来源：origin: org.apache.servicemix.transaction/org.apache.servicemix.transaction

byte[][] record = tx.getRecord();
short recordSize = 0;
for(int j=0; j < record.length; ++j)

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.howl

byte[][] record = tx.getRecord();
short recordSize = 0;
for(int j=0; j < record.length; ++j)

代码示例来源：origin: apache/felix

byte[][] record = tx.getRecord();

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.howl

byte[][] record = tx.getRecord();

代码示例来源：origin: org.apache.servicemix.transaction/org.apache.servicemix.transaction

byte[][] record = tx.getRecord();