com.arjuna.ats.internal.jta.transaction.arjunacore.jca.XATerminatorImple类的使用及代码示例-6ren

com.arjuna.ats.internal.jta.transaction.arjunacore.jca.XATerminatorImple类的使用及代码示例

转载作者：知者更新时间：2024-03-27 01:15:05

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

XATerminatorImple介绍

[英]The XATerminator implementation.
[中]XATerminator实现。

代码示例

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

private static void initXATerminator()
{
  if(txType == null) {
    setTxType( guessTxType() );
  }
  TransactionManager tm = com.arjuna.ats.jta.TransactionManager.transactionManager();
  
  if(txType == TxType.JTA)
  {
    // we are running in JTA mode
    xaTerminator = new XATerminatorImple();
  }
  else
  {
    // it's not JTA, so it must be JTAX. However, we are in the JTA module and
    // can't link against the JTS code so we need to do it the hard way...
    try
    {
      Class clazz = Class.forName("com.arjuna.ats.internal.jta.transaction.jts.jca.XATerminatorImple");
      xaTerminator = (XATerminator)clazz.newInstance();
    }
    catch(Exception e)
    {
      jtaLogger.i18NLogger.error_transaction_arjunacore_jca_SubordinationManager_terminatorfailure(e);
    }
  }
}

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

public Xid[] getXidsToRecoverForParentNode(boolean recoverInFlight, String parentNodeName, int recoveryFlags) throws XAException {
  final Set<Xid> xidsToRecover = new HashSet<Xid>();
  if (recoverInFlight) {
    final TransactionImporter transactionImporter = SubordinationManager.getTransactionImporter();
    if (transactionImporter instanceof TransactionImporterImple) {
      final Set<Xid> inFlightXids = ((TransactionImporterImple) transactionImporter).getInflightXids(parentNodeName);
      if (inFlightXids != null) {
        xidsToRecover.addAll(inFlightXids);
      }
    }
  }
  final javax.resource.spi.XATerminator xaTerminator = SubordinationManager.getXATerminator();
  if (xaTerminator instanceof XATerminatorImple) {
    final Xid[] inDoubtTransactions = ((XATerminatorImple) xaTerminator).doRecover(null, parentNodeName);
    if (inDoubtTransactions != null) {
      xidsToRecover.addAll(Arrays.asList(inDoubtTransactions));
    }
  } else {
    final Xid[] inDoubtTransactions = xaTerminator.recover(recoveryFlags);
    if (inDoubtTransactions != null) {
      xidsToRecover.addAll(Arrays.asList(inDoubtTransactions));
    }
  }
  return xidsToRecover.toArray(NO_XIDS);
}

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

@Test
public void test () throws Exception
  XATerminatorImple term = new XATerminatorImple();
  XidImple xid = new XidImple(new Uid());
  SubordinationManager.getTransactionImporter().importTransaction(xid);
  assertTrue(term.beforeCompletion(xid));
  assertEquals(term.prepare(xid), XAResource.XA_RDONLY);
  SubordinationManager.getTransactionImporter().importTransaction(xid);
  term.commit(xid, true);
  SubordinationManager.getTransactionImporter().importTransaction(xid);
  term.rollback(xid);
  SubordinationManager.getTransactionImporter().importTransaction(xid);
  term.recover(XAResource.TMSTARTRSCAN);
    term.recover(XAResource.TMSTARTRSCAN);
  term.recover(XAResource.TMENDRSCAN);
  term.forget(xid);

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

TransactionImporter imp = SubordinationManager.getTransactionImporter();
XATerminatorImple xa = new XATerminatorImple();
subordinateTransaction.enlistResource(xar2);
xa.prepare(xid);
try {
  xa.commit(xid, false);
  fail("Did not expect to pass");
} catch (XAException xae) {
RecoveryManager.manager().addModule(xarm);
Xid[] xids = xa.recover(XAResource.TMSTARTRSCAN);
assertTrue(Arrays.binarySearch(xids, xid, new Comparator<Xid>() {
  @Override
xa.rollback(xid);
assertTrue(xar2.rollbackCalled());
xa.recover(XAResource.TMENDRSCAN);

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

@Test
public void testRecovery() throws Exception {
  Implementations.initialise();
  XATerminatorImple xa = new XATerminatorImple();
  Xid[] recover = xa.recover(XAResource.TMSTARTRSCAN);
  int initialLength = recover == null ? 0 : recover.length;
  xa.recover(XAResource.TMENDRSCAN);
  assertTrue(xa.beforeCompletion(xid));
  assertEquals(xa.prepare(xid), XAResource.XA_OK);
    xa.commit(xid, false);
    fail();
  } catch (XAException e) {
  Xid[] recover2 = xa.recover(XAResource.TMSTARTRSCAN);
  assertTrue(recover2.length == initialLength+1);
  try {
    xa.commit(xid, false);
    fail();
  } catch (XAException e) {
    assertTrue("Wrong errorcode" + e.errorCode, e.errorCode == XAException.XAER_RMFAIL);
  xa.recover(XAResource.TMENDRSCAN);
  RecoveryManager.manager().addModule(module);
  try {
    Xid[] recover3 = xa.recover(XAResource.TMSTARTRSCAN);
    assertTrue(recover3.length == recover2.length);

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

XATerminatorImple xaTerminator = new XATerminatorImple();
XidImple xid = new XidImple(new Uid());
XAResourceImple toCommit = new XAResourceImple(XAResource.XA_OK, XAResource.XA_OK);
  SubordinateTransaction subordinateTransaction = SubordinationManager.getTransactionImporter().importTransaction(xid);
  tm.resume(subordinateTransaction);
  subordinateTransaction.enlistResource(new XAResourceImple(XAResource.XA_RDONLY, XAResource.XA_OK));
  SubordinateTransaction subordinateTransaction = SubordinationManager.getTransactionImporter().getImportedTransaction(xid);
  tm.resume(subordinateTransaction);
  subordinateTransaction.doPrepare();
xaTerminator.doRecover(null, null);
  SubordinateTransaction subordinateTransaction = SubordinationManager.getTransactionImporter().getImportedTransaction(xid);
  tm.resume(subordinateTransaction);
  subordinateTransaction.doCommit();

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

@Test
public void testInvalid () throws Exception
  XATerminatorImple term = new XATerminatorImple();
  XidImple xid = new XidImple(new Uid());
    SubordinationManager.getTransactionImporter().importTransaction(null);
    SubordinationManager.getTransactionImporter().recoverTransaction(null);
    SubordinationManager.getTransactionImporter().getImportedTransaction(null);

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

@Test
public void testUnknownTransaction () throws Exception
  XATerminatorImple term = new XATerminatorImple();
  XidImple xid = new XidImple(new Uid());
    term.beforeCompletion(xid);
    term.prepare(xid);
    term.commit(xid, false);
    term.rollback(xid);
    term.forget(xid);

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

return doRecover(null, null);

代码示例来源：origin: org.jboss.teiid/teiid-txn-jbossts

commit(xid, false);
  return XAResource.XA_RDONLY;
case TwoPhaseOutcome.PREPARE_NOTOK:
  rollback(xid);
  throw new XAException(XAException.XA_RBROLLBACK);
case TwoPhaseOutcome.PREPARE_OK:

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

XATerminatorImple term = new XATerminatorImple();
XidImple xid = new XidImple(new Uid());
SubordinationManager.getTransactionImporter().importTransaction(xid);
  term.commit(xid, false);
  term.commit(xid, false);
term.prepare(xid);
  term.commit(xid, false);
  term.commit(xid, false);
  term.rollback(xid);
term.prepare(xid);
  term.rollback(xid);
term.prepare(xid);
  term.rollback(xid);
  term.prepare(xid);
  term.prepare(xid);
  term.prepare(xid);

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

return doRecover(null, null);

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

public Xid[] getXidsToRecoverForParentNode(boolean recoverInFlight, String parentNodeName, int recoveryFlags) throws XAException {
  final Set<Xid> xidsToRecover = new HashSet<Xid>();
  if (recoverInFlight) {
    final TransactionImporter transactionImporter = SubordinationManager.getTransactionImporter();
    if (transactionImporter instanceof TransactionImporterImple) {
      final Set<Xid> inFlightXids = ((TransactionImporterImple) transactionImporter).getInflightXids(parentNodeName);
      if (inFlightXids != null) {
        xidsToRecover.addAll(inFlightXids);
      }
    }
  }
  final javax.resource.spi.XATerminator xaTerminator = SubordinationManager.getXATerminator();
  if (xaTerminator instanceof XATerminatorImple) {
    final Xid[] inDoubtTransactions = ((XATerminatorImple) xaTerminator).doRecover(null, parentNodeName);
    if (inDoubtTransactions != null) {
      xidsToRecover.addAll(Arrays.asList(inDoubtTransactions));
    }
  } else {
    final Xid[] inDoubtTransactions = xaTerminator.recover(recoveryFlags);
    if (inDoubtTransactions != null) {
      xidsToRecover.addAll(Arrays.asList(inDoubtTransactions));
    }
  }
  return xidsToRecover.toArray(NO_XIDS);
}

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

private static void initXATerminator()
{
  if(txType == null) {
    setTxType( guessTxType() );
  }
  TransactionManager tm = com.arjuna.ats.jta.TransactionManager.transactionManager();
  
  if(txType == TxType.JTA)
  {
    // we are running in JTA mode
    xaTerminator = new XATerminatorImple();
  }
  else
  {
    // it's not JTA, so it must be JTAX. However, we are in the JTA module and
    // can't link against the JTS code so we need to do it the hard way...
    try
    {
      Class clazz = Class.forName("com.arjuna.ats.internal.jta.transaction.jts.jca.XATerminatorImple");
      xaTerminator = (XATerminator)clazz.newInstance();
    }
    catch(Exception e)
    {
      jtaLogger.i18NLogger.error_transaction_arjunacore_jca_SubordinationManager_terminatorfailure(e);
    }
  }
}

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

return doRecover(null, null);

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

public Xid[] getXidsToRecoverForParentNode(boolean recoverInFlight, String parentNodeName, int recoveryFlags) throws XAException {
  final Set<Xid> xidsToRecover = new HashSet<Xid>();
  if (recoverInFlight) {
    final TransactionImporter transactionImporter = SubordinationManager.getTransactionImporter();
    if (transactionImporter instanceof TransactionImporterImple) {
      final Set<Xid> inFlightXids = ((TransactionImporterImple) transactionImporter).getInflightXids(parentNodeName);
      if (inFlightXids != null) {
        xidsToRecover.addAll(inFlightXids);
      }
    }
  }
  final javax.resource.spi.XATerminator xaTerminator = SubordinationManager.getXATerminator();
  if (xaTerminator instanceof XATerminatorImple) {
    final Xid[] inDoubtTransactions = ((XATerminatorImple) xaTerminator).doRecover(null, parentNodeName);
    if (inDoubtTransactions != null) {
      xidsToRecover.addAll(Arrays.asList(inDoubtTransactions));
    }
  } else {
    final Xid[] inDoubtTransactions = xaTerminator.recover(recoveryFlags);
    if (inDoubtTransactions != null) {
      xidsToRecover.addAll(Arrays.asList(inDoubtTransactions));
    }
  }
  return xidsToRecover.toArray(NO_XIDS);
}

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

private static void initXATerminator()
{
  if(txType == null) {
    setTxType( guessTxType() );
  }
  TransactionManager tm = com.arjuna.ats.jta.TransactionManager.transactionManager();
  
  if(txType == TxType.JTA)
  {
    // we are running in JTA mode
    xaTerminator = new XATerminatorImple();
  }
  else
  {
    // it's not JTA, so it must be JTAX. However, we are in the JTA module and
    // can't link against the JTS code so we need to do it the hard way...
    try
    {
      Class clazz = Class.forName("com.arjuna.ats.internal.jta.transaction.jts.jca.XATerminatorImple");
      xaTerminator = (XATerminator)clazz.newInstance();
    }
    catch(Exception e)
    {
      jtaLogger.i18NLogger.error_transaction_arjunacore_jca_SubordinationManager_terminatorfailure(e);
    }
  }
}

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

return doRecover(null, null);

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

public Xid[] getXidsToRecoverForParentNode(boolean recoverInFlight, String parentNodeName, int recoveryFlags) throws XAException {
  final Set<Xid> xidsToRecover = new HashSet<Xid>();
  if (recoverInFlight) {
    final TransactionImporter transactionImporter = SubordinationManager.getTransactionImporter();
    if (transactionImporter instanceof TransactionImporterImple) {
      final Set<Xid> inFlightXids = ((TransactionImporterImple) transactionImporter).getInflightXids(parentNodeName);
      if (inFlightXids != null) {
        xidsToRecover.addAll(inFlightXids);
      }
    }
  }
  final javax.resource.spi.XATerminator xaTerminator = SubordinationManager.getXATerminator();
  if (xaTerminator instanceof XATerminatorImple) {
    final Xid[] inDoubtTransactions = ((XATerminatorImple) xaTerminator).doRecover(null, parentNodeName);
    if (inDoubtTransactions != null) {
      xidsToRecover.addAll(Arrays.asList(inDoubtTransactions));
    }
  } else {
    final Xid[] inDoubtTransactions = xaTerminator.recover(recoveryFlags);
    if (inDoubtTransactions != null) {
      xidsToRecover.addAll(Arrays.asList(inDoubtTransactions));
    }
  }
  return xidsToRecover.toArray(NO_XIDS);
}

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

private static void initXATerminator()
{
  if(txType == null) {
    setTxType( guessTxType() );
  }
  TransactionManager tm = com.arjuna.ats.jta.TransactionManager.transactionManager();
  
  if(txType == TxType.JTA)
  {
    // we are running in JTA mode
    xaTerminator = new XATerminatorImple();
  }
  else
  {
    // it's not JTA, so it must be JTAX. However, we are in the JTA module and
    // can't link against the JTS code so we need to do it the hard way...
    try
    {
      Class clazz = Class.forName("com.arjuna.ats.internal.jta.transaction.jts.jca.XATerminatorImple");
      xaTerminator = (XATerminator)clazz.newInstance();
    }
    catch(Exception e)
    {
      jtaLogger.i18NLogger.error_transaction_arjunacore_jca_SubordinationManager_terminatorfailure(e);
    }
  }
}

文章推荐： com.chenlb.mmseg4j.Word.getEndOffset()方法的使用及代码示例

c# - C#'s "protected internal”表示 "protected"*OR* "internal"。是否有关键字表示 "protected"*AND* "internal"？
这个问题在这里已经有了答案: How to make a property protected AND internal in C#? (8 个答案) 关闭 9 年前。我需要声明一个既受又内部保
java - Kotlin:符号在模块 'jdk.internal.opt' 中声明，该模块不导出包 'jdk.internal.joptsimple.internal'
我对在 Kotlin 1.3 中使用 Strings.isNullOrEmpty 导入 jdk.internal.joptsimple.internal.Strings.isNullOrEmpty 的
intern - 通过 Selenium 运行测试时在 Intern 目录之外加载依赖项
我有一个项目，实习生单元测试应该位于与被测源代码不同的目录树中。有点像这样: projectRoot projectRoot/src projectRoot/tests projectRoot/tes
intern - 如何从 Intern 功能测试访问全局 JavaScript 范围？
如何在功能测试中访问浏览器的主要 JavaScript 范围？例如，我想获取对 Dojo 小部件的引用并检查它的属性。例如，在浏览器 JavaScript 控制台中，我可以运行: dijit.
c# - Protected Internal 和 Internal Protected 之间有区别吗？
public class TestClass { protected internal int FieldA; internal protected int FieldB; }
c# - 为什么 internal protected 没有比 internal 更严格？
我想创建一个内部自动属性: internal bool IP { get; protected internal set; } 我认为可以使 setter protected 或 protected
java.lang.NoSuchMethodError : okhttp3. internal.Internal.initializeInstanceForTests() 在Android上创建模拟服务器时
java.lang.NoSuchMethodError: okhttp3.internal.Internal.initializeInstanceForTests() When creating a
intern - 如何运行 intern 来测试使用 node.js 运行的 dojo 应用程序？
我正在尝试使用 intern 来测试在 node.js 下运行的 dojo 应用程序我的 intern.js 配置文件是这样的: define({ loader: {
wordpress - Nginx 'rewrite or internal redirection cycle while internally redirecting' 导致 500
我在 Raspbian wheezy 上的 nginx 1.2.1-2.2 有点问题。我认为它是在我更改站点可用/默认文件中的索引后开始的。以下是相关文件: nginx.conf user www-d
visual-studio-2012 - Microsoft.Internal.Assumes+InternalErrorException : Internal error occurred
我在尝试加载 Visual studio 2012 时遇到了此错误，遇到了异常。这可能是由扩展引起的，并且在 C:\Users\~\AppData 中给出了附加信息的位置\Roaming\Micros
java - MockClassLoader无法访问jdk/internal/reflect父类(super class)jdk.internal.reflect.MagicAccessorImpl
我正在将一个项目迁移到 Java9，在我切换到新的 Java 版本后，测试开始失败，看起来 PowerMock 正在尝试访问一些它无法访问的类。 Tests run: 1, Failures: 0,
firebase - "Error: 13 INTERNAL: An internal error occurred"有时发生在 firebase-function 的触发器中
该触发器用于检测进度中的顺序是否已更新，并有助于更新进度的概览状态和完成时间。但是当发生内部错误时，它并不总是有效，如下所示: Error: 13 INTERNAL: An internal err
javascript - eclipse JSDT : internal error NoClassDefFoundError: jdk/nashorn/internal/runtime/ECMAException
当我尝试将包含一些 JavaScript 的项目导入工作区时(使用 Eclipse 的 Neon.M6 版本)，出现此错误: eclipse.buildId=4.6.0.I20160317-0200
java - 由 : java. lang.NoSuchMethodError : com. squareup.okhttp.internal.Internal.getHttpUrlChecked 引起
我在尝试访问 FullContact API 服务器时收到此错误。我正在使用 okhttp 2.7.5 和 okhttp-urlconnection 2.7.5 以及改造 1.9.0。 Caused
python - 导入错误 : No module named 'pandas.core.internals.managers' ; 'pandas.core.internals' is not a package
当我试图读取一个以前版本的 pandas 保存的 pickle 文件时，它产生了一个 ImportError。 ImportError: No module named 'pandas.core.in
java - MockClassLoader 无法访问 jdk/internal/reflect 父类(super class) jdk.internal.reflect.MagicAccessorImpl
我正在将一个项目迁移到 Java9，在我切换到新的 Java 版本后测试开始失败，似乎 PowerMock 正在尝试访问它无法访问的一些类。 Tests run: 1, Failures: 0, Er
redirect - Lumen + nginx = error 500, rewrite or internal redirection cycle while internally redirecting to "/index.php"
我正在尝试设置 Lumen - 建立在 Laravel 组件之上的“微框架”。服务器端有 nginx + php-fpm。这是我的 nginx 配置: server { server_nam
c++ - 链接错误与 fmt : undefined reference to `std::string fmt::v6::internal::grouping_impl(fmt::v6::internal::locale_ref)'
在我们的项目中，我们决定在我们的项目中使用最新的 fmt 版本 (6.2.0) 并主要使用 printf 功能，因为我们在广泛使用 printf 的地方进行日志记录。我使用 fmt 包中包含的 CM
java.lang.NoSuchMethodError : org. mockito.internal.runners.RunnerFactory.createStrict(Ljava/lang/Class;)Lorg/mockito/internal/runners/InternalRunner;
我正在使用 Mockito jar 为 Groovy 编写 Junit 测试用例，但它给了我以下异常: java.lang.NoSuchMethodError: org.mockito.interna
java.lang.NoClassDefFoundError : com/google/common/base/internal/Finalizer$ShutDown (wrong name: com/google/common/base/internal/Finalizer)
我们的应用程序使用 Google 集合中的 MapMaker 类，并且我们遇到了以下异常，但仅限于使用 webstart 的 OS X 10.4。从应用程序包启动时以及在 OS X 10.5 和 Wi

知者

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城

com.arjuna.ats.internal.jta.transaction.arjunacore.jca.XATerminatorImple类的使用及代码示例

XATerminatorImple介绍

代码示例