com.arjuna.ats.internal.jta.resources.arjunacore.XAResourceRecord类的使用及代码示例

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

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

XAResourceRecord介绍

暂无

代码示例

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

  1. public static AbstractRecord create()
  2. {
  3.   return new XAResourceRecord();
  4. }

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

  1. protected int recover()
  2. {
  3.   if (jtaLogger.logger.isTraceEnabled()) {
  4.     jtaLogger.logger.trace("XAResourceRecord.recover");
  5.   }
  6.   if (_committed)
  7.   {
  8.     /*
  9.      * A previous commit attempt failed, but we know the intention
  10.      * was to commit. So let's try again.
  11.      */
  12.     
  13.     if (topLevelCommit() == TwoPhaseOutcome.FINISH_OK)
  14.       return XARecoveryResource.RECOVERED_OK;
  15.     else
  16.       return XARecoveryResource.FAILED_TO_RECOVER;
  17.   }
  18.   else
  19.     return XARecoveryResource.WAITING_FOR_RECOVERY;
  20. }

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

  1. public int topLevelPrepare()
  2.     jtaLogger.logger.trace("XAResourceRecord.topLevelPrepare for " + this + ", record id=" + order());
  3.     jtaLogger.i18NLogger.warn_resources_arjunacore_preparenulltx("XAResourceRecord.prepare");
  4.         removeConnection();
  5.     endAssociation(XAResource.TMSUCCESS, TxInfo.NOT_ASSOCIATED);
  6.     if (_theXAResource.prepare(_tranID) == XAResource.XA_RDONLY)
  7.         removeConnection();
  8.     addDeferredThrowable(e1);
  9.     jtaLogger.i18NLogger.warn_resources_arjunacore_preparefailed(XAHelper.xidToString(_tranID),
  10.         _theXAResource.toString(), XAHelper.printXAErrorCode(e1), e1);
  11.       removeConnection();
  12.     jtaLogger.i18NLogger.warn_resources_arjunacore_preparefailed(XAHelper.xidToString(_tranID),
  13.         _theXAResource.toString(), "-", e2);
  14.       removeConnection();

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

  1. public boolean forgetHeuristic()
  2. {
  3.   if (jtaLogger.logger.isTraceEnabled()) {
  4.     jtaLogger.logger.trace("XAResourceRecord.forget for " + this);
  5.   }
  6.   forget();
  7.   removeConnection();
  8.   return true;
  9. }

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

  1. jtaLogger.logger.trace("XAResourceRecord.topLevelOnePhaseCommit for " + this + ", record id=" + order());
  2. jtaLogger.i18NLogger.warn_resources_arjunacore_opcnulltx("XAResourceRecord.1pc");
  3.     endAssociation(XAResource.TMSUCCESS, TxInfo.NOT_ASSOCIATED);
  4.       default:
  5.       addDeferredThrowable(e1);
  6.       removeConnection();
  7.     addDeferredThrowable(e1);
  8.     jtaLogger.i18NLogger.warn_resources_arjunacore_opcerror(XAHelper.xidToString(_tranID),
  9.       return TwoPhaseOutcome.HEURISTIC_HAZARD;
  10.     case XAException.XA_HEURCOM:
  11.       forget();
  12.       break;
  13.     case XAException.XA_HEURRB:
  14.         forget();
  15.         return TwoPhaseOutcome.ONE_PHASE_ERROR;
  16.     case XAException.XA_RBROLLBACK:
  17.     removeConnection();

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

  1. public int topLevelAbort()
  2.     jtaLogger.logger.trace("XAResourceRecord.topLevelAbort for " + this + ", record id=" + order());
  3.     jtaLogger.i18NLogger.warn_resources_arjunacore_rollbacknulltx("XAResourceRecord.rollback");
  4.       _theXAResource = getNewXAResource();
  5.           endAssociation(XAResource.TMFAIL, TxInfo.FAILED);
  6.         addDeferredThrowable(e1);
  7.               addDeferredThrowable(e2);
  8.                     removeConnection();
  9.           removeConnection();
  10.         _theXAResource.rollback(_tranID);
  11.         if (notAProblem(e1, false))
  12.           addDeferredThrowable(e1);
  13.           jtaLogger.i18NLogger.warn_resources_arjunacore_rollbackerror(XAHelper.xidToString(_tranID),
  14.           removeConnection();

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

  1. public int topLevelCommit()
  2.     jtaLogger.logger.trace("XAResourceRecord.topLevelCommit for " + this + ", record id=" + order());
  3.     jtaLogger.i18NLogger.warn_resources_arjunacore_commitnulltx("XAResourceRecord.commit");
  4.       _theXAResource = getNewXAResource();
  5.         _theXAResource.commit(_tranID, false);
  6.         if (notAProblem(e1, true))
  7.           addDeferredThrowable(e1);
  8.           jtaLogger.i18NLogger.warn_resources_arjunacore_commitxaerror(XAHelper.xidToString(_tranID),
  9.               _theXAResource.toString(), XAHelper.printXAErrorCode(e1), e1);
  10.         jtaLogger.i18NLogger.warn_resources_arjunacore_commitxaerror(XAHelper.xidToString(_tranID),
  11.               _theXAResource.toString(), "-", e2);
  12.         removeConnection();
  13.       else if (_jndiName != null && wasResourceContactedByRecoveryModule(_jndiName))
  14.         jtaLogger.i18NLogger.info_resources_arjunacore_rmcompleted(XAHelper.xidToString(_tranID));

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

  1. if (endAssociation())
  2.   _theXAResource.end(_tranID, XAResource.TMSUCCESS);
  3.           new Object[] { _tranID, _theXAResource, XAHelper.printXAErrorCode(e1) }, e1);
  4.   removeConnection();
  5.   _theXAResource.commit(_tranID, true);
  6. else
  7.   _theXAResource.rollback(_tranID);
  8.       new Object[] { _tranID, _theXAResource, XAHelper.printXAErrorCode(e1) }, e1);
  9.   return TwoPhaseOutcome.HEURISTIC_HAZARD;
  10. case XAException.XA_HEURCOM:
  11.   forget();
  12.   break;
  13. case XAException.XA_HEURRB:
  14.     forget();
  15.     return TwoPhaseOutcome.ONE_PHASE_ERROR;
  16. case XAException.XA_RBROLLBACK:
  17. removeConnection();

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

  1. _theXAResource = getNewXAResource();
  2.     if (endAssociation())
  3.       _theXAResource.end(_tranID, XAResource.TMSUCCESS);
  4.           new Object[] { _tranID, _theXAResource, XAHelper.printXAErrorCode(e1) }, e1);
  5.     removeConnection();
  6.   _theXAResource.rollback(_tranID);
  7.   if (notAProblem(e1, false))
  8.           new Object[] { _tranID, _theXAResource, XAHelper.printXAErrorCode(e1) }, e1);
  9.     removeConnection();

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

  1. removeConnection();
  2. removeConnection();
  3. if (endAssociation())
  4.   _theXAResource.end(_tranID, XAResource.TMSUCCESS);
  5. if (_theXAResource.prepare(_tranID) == XAResource.XA_RDONLY)
  6.     removeConnection();
  7.       new Object[] { _tranID, _theXAResource, XAHelper.printXAErrorCode(e1) }, e1);
  8.   removeConnection();
  9.   removeConnection();

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

  1. _theXAResource = getNewXAResource();
  2.   _theXAResource.commit(_tranID, false);
  3.   if (notAProblem(e1, true))
  4.           new Object[] { _tranID, _theXAResource, XAHelper.printXAErrorCode(e1) }, e1);
  5.   removeConnection();

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

  1. Iterator<SerializableXAResourceDeserializer> iterator = getXAResourceDeserializers().iterator();
  2.       while (iterator.hasNext()) {
  3.         SerializableXAResourceDeserializer proxyXAResourceDeserializer = iterator.next();
  4.           jtaLogger.i18NLogger.warn_resources_arjunacore_classnotfound(className);
  5.           haveXAResource = false;
  6.       jtaLogger.i18NLogger.warn_resources_arjunacore_restorestate(ex);
  7.     _theXAResource = getNewXAResource();
  8.       jtaLogger.i18NLogger.warn_resources_arjunacore_norecoveryxa( toString() );
  9. jtaLogger.i18NLogger.warn_resources_arjunacore_restorestateerror(_theXAResource.toString(), XAHelper.xidToString(_tranID), e);

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

  1. jtaLogger.i18NLogger.warn_resources_arjunacore_restorestate(ex);
  2.     _theXAResource = getNewXAResource();
  3.       jtaLogger.i18NLogger.warn_resources_arjunacore_norecoveryxa( toString() );
  4. jtaLogger.i18NLogger.warn_resources_arjunacore_restorestateerror(_theXAResource.toString(), XAHelper.xidToString(_tranID), e);

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

  1. @Test
  2. public void testInvalid () throws Exception
  3. {
  4.   XAResourceRecord xares = new XAResourceRecord();
  5.   
  6.   assertEquals(xares.getXid(), null);
  7.   assertEquals(xares.value(), null);
  8.   assertEquals(xares.topLevelOnePhaseCommit(), TwoPhaseOutcome.ONE_PHASE_ERROR);
  9.   assertEquals(xares.topLevelPrepare(), TwoPhaseOutcome.PREPARE_NOTOK);
  10.   assertEquals(xares.topLevelAbort(), TwoPhaseOutcome.FINISH_ERROR);
  11.   assertEquals(xares.topLevelCommit(), TwoPhaseOutcome.FINISH_ERROR);
  12. }

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

  1. @Test
  2. public void test () throws Exception
  3. {
  4.   XAResourceRecord xares = new XAResourceRecord();
  5.   Object obj = new Object();
  6.   
  7.   xares.setValue(obj);
  8.   
  9.   assertTrue(xares.value() != obj);
  10.   
  11.   DummyRecoverableXAConnection rc = new DummyRecoverableXAConnection();
  12.   Object[] params = new Object[1];
  13.   
  14.   params[XAResourceRecord.XACONNECTION] = rc;
  15.   
  16.   xares = new XAResourceRecord(new TransactionImple(0), new DummyXA(false), new XidImple(new Uid()), params);
  17.   
  18.   assertTrue(xares.type() != null);
  19.   
  20.   xares.merge(xares);
  21.   xares.replace(xares);
  22.   
  23.   assertTrue(xares.toString() != null);
  24. }

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

  1. @Test
  2. public void testCommitFailure () throws Exception
  3. {
  4.   FailureXAResource fxa = new FailureXAResource(FailureXAResource.FailLocation.commit);
  5.   TransactionImple tx = new TransactionImple(0);
  6.   XAResourceRecord xares = new XAResourceRecord(tx, fxa, tx.getTxId(), null);
  7.   
  8.   assertEquals(xares.topLevelPrepare(), TwoPhaseOutcome.PREPARE_OK);
  9.   assertEquals(xares.topLevelCommit(), TwoPhaseOutcome.HEURISTIC_MIXED);
  10.   assertTrue(xares.forgetHeuristic());
  11. }

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

  1. @Test
  2. public void testValid2PC () throws Exception
  3. {
  4.   TransactionImple tx = new TransactionImple(0);
  5.   DummyXA res = new DummyXA(false);
  6.   XAResourceRecord xares = new XAResourceRecord(tx, res, tx.getTxId(), null);
  7.   
  8.   assertEquals(xares.topLevelPrepare(), TwoPhaseOutcome.PREPARE_OK);
  9.   assertEquals(xares.topLevelCommit(), TwoPhaseOutcome.FINISH_OK);
  10. }

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

  1. @Test
  2. public void testRollbackFailure () throws Exception
  3. {
  4.   FailureXAResource fxa = new FailureXAResource(FailureXAResource.FailLocation.rollback);
  5.   TransactionImple tx = new TransactionImple(0);
  6.   XAResourceRecord xares = new XAResourceRecord(tx, fxa, tx.getTxId(), null);
  7.   
  8.   assertEquals(xares.topLevelPrepare(), TwoPhaseOutcome.PREPARE_OK);
  9.   assertEquals(xares.topLevelAbort(), TwoPhaseOutcome.HEURISTIC_MIXED);
  10.   assertTrue(xares.forgetHeuristic());
  11. }

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

  1. public int recover ()
  2. {
  3. return super.recover();
  4. }

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

  1. @Test
  2.   public void testNested () throws Exception
  3.   {
  4.     XAResourceRecord xares = new XAResourceRecord();
  5.     
  6.     assertEquals(xares.nestedOnePhaseCommit(), TwoPhaseOutcome.FINISH_ERROR);
  7.     assertEquals(xares.nestedPrepare(), TwoPhaseOutcome.PREPARE_OK);
  8.     assertEquals(xares.nestedCommit(), TwoPhaseOutcome.FINISH_OK);
  9.     assertEquals(xares.nestedAbort(), TwoPhaseOutcome.FINISH_OK);
  10.   }
  11. }

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

XAResourceRecord

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    XAResourceRecord类方法

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