gpt4 book ai didi

com.arjuna.ats.jta.recovery.XAResourceOrphanFilter.checkXid()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-21 00:31:05 32 4
gpt4 key购买 nike

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

XAResourceOrphanFilter.checkXid介绍

[英]Called by the XARecoveryModule for each in-doubt Xid. Implementations should return Vote.ROLLBACK if they recognize the xid and believe it should be aborted. Vote.LEAVE_ALONE if they recognize the xid and do not want the XARecovery module to roll it back. Vote.ABSTAIN if they do not recognize the xid. Each registered XAResourceOrphanFilter will be consulted before any rollback on each recovery pass, so they may change their mind over time e.g. if new information becomes available due to other recovery activity.
[中]由XARecoveryModule为每个有疑问的Xid调用。实现应该返回投票。如果他们认识到xid并认为应该中止,请回滚。选票如果他们识别出xid并且不希望XARecovery模块将其回滚,请不要打扰_。选票如果他们不认识xid,就弃权。在每次恢复过程中进行任何回滚之前,将咨询每个已注册的筛选器,因此他们可能会随着时间的推移而改变主意,例如,如果由于其他恢复活动而获得新信息。

代码示例

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

@Override
  public Vote checkXid(Xid xid)
  {
    if(xid.getFormatId() != myFormatId) {
      return Vote.ABSTAIN;
    }

    return nodeNameFilter.checkXid(xid);
  }
}

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

@Override
  public Vote checkXid(Xid xid)
  {
    if(xid.getFormatId() != myFormatId) {
      return Vote.ABSTAIN;
    }

    return nodeNameFilter.checkXid(xid);
  }
}

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

@Override
  public Vote checkXid(Xid xid)
  {
    if(xid.getFormatId() != myFormatId) {
      return Vote.ABSTAIN;
    }

    return nodeNameFilter.checkXid(xid);
  }
}

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

@Override
  public Vote checkXid(Xid xid)
  {
    if(xid.getFormatId() != myFormatId) {
      return Vote.ABSTAIN;
    }

    return nodeNameFilter.checkXid(xid);
  }
}

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

@Override
  public Vote checkXid(Xid xid)
  {
    if(xid.getFormatId() != myFormatId) {
      return Vote.ABSTAIN;
    }

    return nodeNameFilter.checkXid(xid);
  }
}

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

@Override
  public Vote checkXid(Xid xid)
  {
    if(xid.getFormatId() != myFormatId) {
      return Vote.ABSTAIN;
    }

    return nodeNameFilter.checkXid(xid);
  }
}

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

XAResourceOrphanFilter.Vote vote = filter.checkXid(xid);

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

XAResourceOrphanFilter.Vote vote = filter.checkXid(xid);

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

XAResourceOrphanFilter.Vote vote = filter.checkXid(xid);

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

XAResourceOrphanFilter.Vote vote = filter.checkXid(xid);

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

XAResourceOrphanFilter.Vote vote = filter.checkXid(xid);

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

XAResourceOrphanFilter.Vote vote = filter.checkXid(xid);

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

@Test
public void testJTATransactionLogOrphanFilter()
{
  XAResourceOrphanFilter orphanFilter = new JTATransactionLogXAResourceOrphanFilter();
  Xid notJTAFormatId = XATxConverter.getXid(new Uid(), false, 0);
  assertEquals(XAResourceOrphanFilter.Vote.ABSTAIN, orphanFilter.checkXid(notJTAFormatId));
  Xid jtaFormatId = XATxConverter.getXid(new Uid(), false, XATxConverter.FORMAT_ID);
  assertEquals(XAResourceOrphanFilter.Vote.ABSTAIN, orphanFilter.checkXid(jtaFormatId));
}

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

@Test
public void testJTANodeNameXAResourceOrphanFilter()
{
  XAResourceOrphanFilter orphanFilter = new JTANodeNameXAResourceOrphanFilter();
  Xid notJTAFormatId = XATxConverter.getXid(new Uid(), false, 0);
  assertEquals(XAResourceOrphanFilter.Vote.ABSTAIN, orphanFilter.checkXid(notJTAFormatId));
  List<String> recoveryNodes = new LinkedList<String>();
  recoveryNodes.add("1");
  jtaPropertyManager.getJTAEnvironmentBean().setXaRecoveryNodes(recoveryNodes);
  String notRecoverableNodeName ="2";
  TxControl.setXANodeName(notRecoverableNodeName);
  Xid jtaNotRecoverableNodeName = XATxConverter.getXid(new Uid(), false, XATxConverter.FORMAT_ID);
  assertEquals(XAResourceOrphanFilter.Vote.ABSTAIN, orphanFilter.checkXid(jtaNotRecoverableNodeName));
  String recoverableNodeName ="1";
  TxControl.setXANodeName(recoverableNodeName);
  Xid jtaRecoverableNodeName = XATxConverter.getXid(new Uid(), false, XATxConverter.FORMAT_ID);
  assertEquals(XAResourceOrphanFilter.Vote.ROLLBACK, orphanFilter.checkXid(jtaRecoverableNodeName));
  recoveryNodes.clear();
  recoveryNodes.add(NodeNameXAResourceOrphanFilter.RECOVER_ALL_NODES);
  jtaPropertyManager.getJTAEnvironmentBean().setXaRecoveryNodes(recoveryNodes);
  assertEquals(XAResourceOrphanFilter.Vote.ROLLBACK, orphanFilter.checkXid(jtaNotRecoverableNodeName));
  assertEquals(XAResourceOrphanFilter.Vote.ROLLBACK, orphanFilter.checkXid(jtaRecoverableNodeName));
}

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

try {
  Xid xid = XATxConverter.getXid(Uid.nullUid(), false, XATxConverter.FORMAT_ID);
  assertEquals(XAResourceOrphanFilter.Vote.ABSTAIN, orphanFilter.checkXid(xid));
  SubordinateTransaction subordinateTransaction = SubordinationManager.getTransactionImporter().importTransaction(xid);
  final List<Xid> xids = new ArrayList<Xid>();
  subordinateTransaction.enlistResource(xar);
  try {
    assertEquals(XAResourceOrphanFilter.Vote.LEAVE_ALONE, orphanFilter.checkXid(xids.get(0)));
  } finally {
    subordinateTransaction.doRollback();
  assertEquals(XAResourceOrphanFilter.Vote.LEAVE_ALONE, orphanFilter.checkXid(xids.get(0)));
  SubordinationManager.getTransactionImporter().removeImportedTransaction(xid);
  assertEquals(XAResourceOrphanFilter.Vote.ROLLBACK, orphanFilter.checkXid(xids.get(0)));
} finally {
  jtaPropertyManager.getJTAEnvironmentBean().setXaRecoveryNodes(xaRecoveryNodes);

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

@Test
public void testJTAActionStatusServiceXAResourceOrphanFilter() {
  XAResourceOrphanFilter orphanFilter = new JTAActionStatusServiceXAResourceOrphanFilter();
  List<String> xaRecoveryNodes = jtaPropertyManager.getJTAEnvironmentBean().getXaRecoveryNodes();
  List<String> recoveryNodes = new LinkedList<String>();
  recoveryNodes.add("1");
  jtaPropertyManager.getJTAEnvironmentBean().setXaRecoveryNodes(recoveryNodes);
  try {
    Uid uid = new Uid();
    Xid xid = XATxConverter.getXid(uid, false, XATxConverter.FORMAT_ID);
    assertEquals(XAResourceOrphanFilter.Vote.ROLLBACK, orphanFilter.checkXid(xid));
    TwoPhaseCoordinator tpc = new TwoPhaseCoordinator(uid);
    try {
      tpc.start();
      assertEquals(XAResourceOrphanFilter.Vote.LEAVE_ALONE, orphanFilter.checkXid(xid));
    } finally {
      tpc.cancel();
    }
    assertEquals(XAResourceOrphanFilter.Vote.ROLLBACK, orphanFilter.checkXid(xid));
    jtaPropertyManager.getJTAEnvironmentBean().setXaRecoveryNodes(null);
    TwoPhaseCoordinator tpc2 = new TwoPhaseCoordinator(uid);
    tpc2.start();
    assertEquals(XAResourceOrphanFilter.Vote.ABSTAIN, orphanFilter.checkXid(xid));
    tpc2.cancel();
  } finally {
    jtaPropertyManager.getJTAEnvironmentBean().setXaRecoveryNodes(xaRecoveryNodes);
  }
}

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

@Test
  public void testSubordinateJTAXAResourceOrphanFilter() throws HeuristicRollbackException, HeuristicMixedException, HeuristicCommitException, SystemException, RollbackException, XAException {
    XAResourceOrphanFilter orphanFilter = new SubordinateJTAXAResourceOrphanFilter();
    XidImple xid = (XidImple) XATxConverter.getXid(Uid.nullUid(), false, XATxConverter.FORMAT_ID);
    XATxConverter.setSubordinateNodeName(xid.getXID(), TxControl.getXANodeName());
    List<String> xaRecoveryNodes = jtaPropertyManager.getJTAEnvironmentBean().getXaRecoveryNodes();
    try {
      jtaPropertyManager.getJTAEnvironmentBean().setXaRecoveryNodes(Arrays.asList("2"));
      assertEquals(XAResourceOrphanFilter.Vote.ABSTAIN, orphanFilter.checkXid(xid));
      jtaPropertyManager.getJTAEnvironmentBean().setXaRecoveryNodes(Arrays.asList("1"));
      assertEquals(XAResourceOrphanFilter.Vote.ROLLBACK, orphanFilter.checkXid(xid));
    } finally {
      jtaPropertyManager.getJTAEnvironmentBean().setXaRecoveryNodes(xaRecoveryNodes);
    }
  }
}

32 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com