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

XAResourceOrphanFilter介绍

[英]Interface used by the XARecoveryModule to allow plugins to vote in the handling of in-doubt Xids.
[中]XARecoveryModule使用的接口，允许插件在处理可疑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);
    }
  }
}