com.arjuna.ats.jta.xa.XATxConverter.getSubordinateNodeName()方法的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(13.5k)|赞(0)|评价(0)|浏览(79)

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

XATxConverter.getSubordinateNodeName介绍

暂无

代码示例

代码示例来源：origin: org.jboss.narayana.jts/narayana-jts-idlj

/**
 * Returning subordinate node name codified inside of the Xid.
 *
 * @param xid  the xid to check the subordinate node name
 * @return  subordinate node name saved in the xid
 */
public static final String getSubordinateNodeName (Xid xid)
{
  return XATxConverter.getSubordinateNodeName(getXIDfromXid(xid));
}

代码示例来源：origin: jbosstm/narayana

/**
 * Returning subordinate node name codified inside of the Xid.
 *
 * @param xid  the xid to check the subordinate node name
 * @return  subordinate node name saved in the xid
 */
public static final String getSubordinateNodeName (Xid xid)
{
  return XATxConverter.getSubordinateNodeName(getXIDfromXid(xid));
}

代码示例来源：origin: org.jboss.narayana.jta/jta

/**
 * Returning subordinate node name codified inside of the Xid.
 *
 * @param xid  the xid to check the subordinate node name
 * @return  subordinate node name saved in the xid
 */
public static final String getSubordinateNodeName (Xid xid)
{
  return XATxConverter.getSubordinateNodeName(getXIDfromXid(xid));
}

代码示例来源：origin: jbosstm/narayana

/**
 * Returning subordinate node name codified inside of the Xid.
 *
 * @param xid  the xid to check the subordinate node name
 * @return  subordinate node name saved in the xid
 */
public static final String getSubordinateNodeName (Xid xid)
{
  return XATxConverter.getSubordinateNodeName(getXIDfromXid(xid));
}

代码示例来源：origin: org.jboss.jbossts/jbossjta

public static String getXIDString(XID xid)
  {
    // companion method to XID.toString - try to keep them in sync.

    StringBuilder stringBuilder = new StringBuilder();
    stringBuilder.append("< formatId=");
    stringBuilder.append(xid.formatID);
    stringBuilder.append(", gtrid_length=");
    stringBuilder.append(xid.gtrid_length);
    stringBuilder.append(", bqual_length=");
    stringBuilder.append(xid.bqual_length);
    stringBuilder.append(", tx_uid=");
    stringBuilder.append(getUid(xid).stringForm());
    stringBuilder.append(", node_name=");
    stringBuilder.append(getNodeName(xid));
    stringBuilder.append(", branch_uid=");
    stringBuilder.append(getBranchUid(xid));;
    stringBuilder.append(", subordinatenodename=");
    stringBuilder.append(getSubordinateNodeName(xid));
    stringBuilder.append(", eis_name=");
    if (xaResourceRecordWrappingPlugin != null) {
      stringBuilder.append(xaResourceRecordWrappingPlugin.getEISName(getEISName(xid)));
    } else {
      stringBuilder.append(getEISName(xid));
    }
    stringBuilder.append(" >");

    return stringBuilder.toString();
  }
}

代码示例来源：origin: org.jboss.narayana.jta/jta

public static String getXIDString(XID xid)
  {
    // companion method to XID.toString - try to keep them in sync.

    StringBuilder stringBuilder = new StringBuilder();
    stringBuilder.append("< formatId=");
    stringBuilder.append(xid.formatID);
    stringBuilder.append(", gtrid_length=");
    stringBuilder.append(xid.gtrid_length);
    stringBuilder.append(", bqual_length=");
    stringBuilder.append(xid.bqual_length);
    stringBuilder.append(", tx_uid=");
    stringBuilder.append(getUid(xid).stringForm());
    stringBuilder.append(", node_name=");
    stringBuilder.append(getNodeName(xid));
    stringBuilder.append(", branch_uid=");
    stringBuilder.append(getBranchUid(xid));;
    stringBuilder.append(", subordinatenodename=");
    stringBuilder.append(getSubordinateNodeName(xid));
    stringBuilder.append(", eis_name=");
    if (xaResourceRecordWrappingPlugin != null) {
      stringBuilder.append(xaResourceRecordWrappingPlugin.getEISName(getEISName(xid)));
    } else {
      stringBuilder.append(getEISName(xid));
    }
    stringBuilder.append(" >");

    return stringBuilder.toString();
  }
}

代码示例来源：origin: org.jboss.jbossts.jta/narayana-jta

public static String getXIDString(XID xid)
  {
    // companion method to XID.toString - try to keep them in sync.

    StringBuilder stringBuilder = new StringBuilder();
    stringBuilder.append("< formatId=");
    stringBuilder.append(xid.formatID);
    stringBuilder.append(", gtrid_length=");
    stringBuilder.append(xid.gtrid_length);
    stringBuilder.append(", bqual_length=");
    stringBuilder.append(xid.bqual_length);
    stringBuilder.append(", tx_uid=");
    stringBuilder.append(getUid(xid).stringForm());
    stringBuilder.append(", node_name=");
    stringBuilder.append(getNodeName(xid));
    stringBuilder.append(", branch_uid=");
    stringBuilder.append(getBranchUid(xid));;
    stringBuilder.append(", subordinatenodename=");
    stringBuilder.append(getSubordinateNodeName(xid));
    stringBuilder.append(", eis_name=");
    if (xaResourceRecordWrappingPlugin != null) {
      stringBuilder.append(xaResourceRecordWrappingPlugin.getEISName(getEISName(xid)));
    } else {
      stringBuilder.append(getEISName(xid));
    }
    stringBuilder.append(" >");

    return stringBuilder.toString();
  }
}

代码示例来源：origin: jbosstm/narayana

public static String getXIDString(XID xid)
  {
    // companion method to XID.toString - try to keep them in sync.

    StringBuilder stringBuilder = new StringBuilder();
    stringBuilder.append("< formatId=");
    stringBuilder.append(xid.formatID);
    stringBuilder.append(", gtrid_length=");
    stringBuilder.append(xid.gtrid_length);
    stringBuilder.append(", bqual_length=");
    stringBuilder.append(xid.bqual_length);
    stringBuilder.append(", tx_uid=");
    stringBuilder.append(getUid(xid).stringForm());
    stringBuilder.append(", node_name=");
    stringBuilder.append(getNodeName(xid));
    stringBuilder.append(", branch_uid=");
    stringBuilder.append(getBranchUid(xid));;
    stringBuilder.append(", subordinatenodename=");
    stringBuilder.append(getSubordinateNodeName(xid));
    stringBuilder.append(", eis_name=");
    if (xaResourceRecordWrappingPlugin != null) {
      stringBuilder.append(xaResourceRecordWrappingPlugin.getEISName(getEISName(xid)));
    } else {
      stringBuilder.append(getEISName(xid));
    }
    stringBuilder.append(" >");

    return stringBuilder.toString();
  }
}

代码示例来源：origin: org.jboss.jbossts/jbossjta

@Override
public Vote checkXid(Xid xid) {
  String nodeName = XATxConverter.getSubordinateNodeName(new XidImple(xid).getXID());
  if (jtaLogger.logger.isDebugEnabled()) {
    jtaLogger.logger.debug("subordinate node name of " + xid + " is " + nodeName);
  }
  // It does have an XID
  if (nodeName != null) {
    if (transactionLog(xid, nodeName)) {
      // it's owned by a logged transaction which
      // will recover it top down in due course
      return Vote.LEAVE_ALONE;
    } else {
      return Vote.ROLLBACK;
    }
  } else {
    return Vote.ABSTAIN;
  }
}

代码示例来源：origin: org.jboss.jbossts.jta/narayana-jta

@Override
public Vote checkXid(Xid xid) {
  List<String> _xaRecoveryNodes = jtaPropertyManager.getJTAEnvironmentBean().getXaRecoveryNodes();
  if(_xaRecoveryNodes == null || _xaRecoveryNodes.size() == 0) {
    jtaLogger.i18NLogger.info_recovery_noxanodes();
    return Vote.ABSTAIN;
  }
  String nodeName = XATxConverter.getSubordinateNodeName(new XidImple(xid).getXID());
  if (jtaLogger.logger.isDebugEnabled()) {
    jtaLogger.logger.debug("subordinate node name of " + xid + " is " + nodeName);
  }
  if (!_xaRecoveryNodes.contains(nodeName)) {
    // It either doesn't have a subordinate node name or isn't for this server
    return Vote.ABSTAIN;
  }
  // It does have an XID
  if (nodeName != null) {
    if (transactionLog(xid, nodeName)) {
      // it's owned by a logged transaction which
      // will recover it top down in due course
      return Vote.ABSTAIN;
    } else {
      return Vote.ROLLBACK;
    }
  } else {
    return Vote.ABSTAIN;
  }
}

代码示例来源：origin: org.jboss.narayana.jts/narayana-jts-idlj

@Override
public Vote checkXid(Xid xid) {
  List<String> _xaRecoveryNodes = jtaPropertyManager.getJTAEnvironmentBean().getXaRecoveryNodes();
  if(_xaRecoveryNodes == null || _xaRecoveryNodes.size() == 0) {
    jtaLogger.i18NLogger.info_recovery_noxanodes();
    return Vote.ABSTAIN;
  }
  String nodeName = XATxConverter.getSubordinateNodeName(new XidImple(xid).getXID());
  if (jtaLogger.logger.isDebugEnabled()) {
    jtaLogger.logger.debug("subordinate node name of " + xid + " is " + nodeName);
  }
  if (!_xaRecoveryNodes.contains(nodeName)) {
    // It either doesn't have a subordinate node name or isn't for this server
    return Vote.ABSTAIN;
  }
  // It does have an XID
  if (nodeName != null) {
    if (transactionLog(xid, nodeName)) {
      // it's owned by a logged transaction which
      // will recover it top down in due course
      return Vote.ABSTAIN;
    } else {
      return Vote.ROLLBACK;
    }
  } else {
    return Vote.ABSTAIN;
  }
}

代码示例来源：origin: jbosstm/narayana

@Override
public Vote checkXid(Xid xid) {
  List<String> _xaRecoveryNodes = jtaPropertyManager.getJTAEnvironmentBean().getXaRecoveryNodes();
  if(_xaRecoveryNodes == null || _xaRecoveryNodes.size() == 0) {
    jtaLogger.i18NLogger.info_recovery_noxanodes();
    return Vote.ABSTAIN;
  }
  String nodeName = XATxConverter.getSubordinateNodeName(new XidImple(xid).getXID());
  if (jtaLogger.logger.isDebugEnabled()) {
    jtaLogger.logger.debug("subordinate node name of " + xid + " is " + nodeName);
  }
  if (!_xaRecoveryNodes.contains(nodeName)) {
    // It either doesn't have a subordinate node name or isn't for this server
    return Vote.ABSTAIN;
  }
  // It does have an XID
  if (nodeName != null) {
    if (transactionLog(xid, nodeName)) {
      // it's owned by a logged transaction which
      // will recover it top down in due course
      return Vote.ABSTAIN;
    } else {
      return Vote.ROLLBACK;
    }
  } else {
    return Vote.ABSTAIN;
  }
}

代码示例来源：origin: jbosstm/narayana

@Override
public Vote checkXid(Xid xid) {
  List<String> _xaRecoveryNodes = jtaPropertyManager.getJTAEnvironmentBean().getXaRecoveryNodes();
  if(_xaRecoveryNodes == null || _xaRecoveryNodes.size() == 0) {
    jtaLogger.i18NLogger.info_recovery_noxanodes();
    return Vote.ABSTAIN;
  }
  String nodeName = XATxConverter.getSubordinateNodeName(new XidImple(xid).getXID());
  if (jtaLogger.logger.isDebugEnabled()) {
    jtaLogger.logger.debug("subordinate node name of " + xid + " is " + nodeName);
  }
  if (!_xaRecoveryNodes.contains(nodeName)) {
    // It either doesn't have a subordinate node name or isn't for this server
    return Vote.ABSTAIN;
  }
  // It does have an XID
  if (nodeName != null) {
    if (transactionLog(xid, nodeName)) {
      // it's owned by a logged transaction which
      // will recover it top down in due course
      return Vote.ABSTAIN;
    } else {
      return Vote.ROLLBACK;
    }
  } else {
    return Vote.ABSTAIN;
  }
}

代码示例来源：origin: org.jboss.narayana.jts/narayana-jts-idlj

public SubordinateAtomicAction (int timeout, Xid xid)
{
  super(timeout); // implicit start (done in base class)
  
  if (xid != null && xid.getFormatId() == XATxConverter.FORMAT_ID) {
    XidImple toImport = new XidImple(xid);
    XID toCheck = toImport.getXID();
    _parentNodeName = XATxConverter.getSubordinateNodeName(toCheck);
    if (_parentNodeName == null) {
      _parentNodeName = XATxConverter.getNodeName(toCheck);
    }
    XATxConverter.setSubordinateNodeName(toImport.getXID(), TxControl.getXANodeName());
    _theXid = new XidImple(toImport);
  } else {
    _theXid = new XidImple(xid);
  }
  
  _activated = true;
}

代码示例来源：origin: org.jboss.jbossts/jbossjta

public SubordinateAtomicAction (int timeout, Xid xid)
{
  super(timeout); // implicit start (done in base class)
  
  if (xid != null && xid.getFormatId() == XATxConverter.FORMAT_ID) {
    XidImple toImport = new XidImple(xid);
    XID toCheck = toImport.getXID();
    _parentNodeName = XATxConverter.getSubordinateNodeName(toCheck);
    if (_parentNodeName == null) {
      _parentNodeName = XATxConverter.getNodeName(toCheck);
    }
    XATxConverter.setSubordinateNodeName(toImport.getXID(), TxControl.getXANodeName());
    _theXid = new XidImple(toImport);
  } else {
    _theXid = new XidImple(xid);
  }
  
  _activated = true;
}

代码示例来源：origin: jbosstm/narayana

public SubordinateAtomicAction (int timeout, Xid xid)
{
  super(timeout); // implicit start (done in base class)
  
  if (xid != null && xid.getFormatId() == XATxConverter.FORMAT_ID) {
    XidImple toImport = new XidImple(xid);
    XID toCheck = toImport.getXID();
    _parentNodeName = XATxConverter.getSubordinateNodeName(toCheck);
    if (_parentNodeName == null) {
      _parentNodeName = XATxConverter.getNodeName(toCheck);
    }
    XATxConverter.setSubordinateNodeName(toImport.getXID(), TxControl.getXANodeName());
    _theXid = new XidImple(toImport);
  } else {
    _theXid = new XidImple(xid);
  }
  
  _activated = true;
}

代码示例来源：origin: org.jboss.narayana.jta/jta

public SubordinateAtomicAction (int timeout, Xid xid)
{
  super(timeout); // implicit start (done in base class)
  
  if (xid != null && xid.getFormatId() == XATxConverter.FORMAT_ID) {
    XidImple toImport = new XidImple(xid);
    XID toCheck = toImport.getXID();
    _parentNodeName = XATxConverter.getSubordinateNodeName(toCheck);
    if (_parentNodeName == null) {
      _parentNodeName = XATxConverter.getNodeName(toCheck);
    }
    XATxConverter.setSubordinateNodeName(toImport.getXID(), TxControl.getXANodeName());
    _theXid = new XidImple(toImport);
  } else {
    _theXid = new XidImple(xid);
  }
  
  _activated = true;
}

代码示例来源：origin: org.jboss.jbossts.jta/narayana-jta

public SubordinateAtomicAction (int timeout, Xid xid)
{
  super(timeout); // implicit start (done in base class)
  
  if (xid != null && xid.getFormatId() == XATxConverter.FORMAT_ID) {
    XidImple toImport = new XidImple(xid);
    XID toCheck = toImport.getXID();
    _parentNodeName = XATxConverter.getSubordinateNodeName(toCheck);
    if (_parentNodeName == null) {
      _parentNodeName = XATxConverter.getNodeName(toCheck);
    }
    XATxConverter.setSubordinateNodeName(toImport.getXID(), TxControl.getXANodeName());
    _theXid = new XidImple(toImport);
  } else {
    _theXid = new XidImple(xid);
  }
  
  _activated = true;
}

代码示例来源：origin: jbosstm/narayana

public SubordinateAtomicAction (int timeout, Xid xid)
{
  super(timeout); // implicit start (done in base class)
  
  if (xid != null && xid.getFormatId() == XATxConverter.FORMAT_ID) {
    XidImple toImport = new XidImple(xid);
    XID toCheck = toImport.getXID();
    _parentNodeName = XATxConverter.getSubordinateNodeName(toCheck);
    if (_parentNodeName == null) {
      _parentNodeName = XATxConverter.getNodeName(toCheck);
    }
    XATxConverter.setSubordinateNodeName(toImport.getXID(), TxControl.getXANodeName());
    _theXid = new XidImple(toImport);
  } else {
    _theXid = new XidImple(xid);
  }
  
  _activated = true;
}

代码示例来源：origin: jbosstm/narayana

@Test
public void testForeignXID() {
  XidImple foreignXidImple = new XidImple(new MyForeignXID());
  assertEquals(XATxConverter.getNodeName(foreignXidImple.getXID()), null);
  assertTrue(XATxConverter.getEISName(foreignXidImple.getXID()) == -1);
  assertEquals(XATxConverter.getSubordinateNodeName(foreignXidImple.getXID()), null);
}

内容来源于网络，如有侵权，请联系作者删除！

XATxConverter

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com