gpt4 book ai didi

bitronix.tm.resource.common.XAResourceProducer.setFailed()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-21 01:17:05 25 4
gpt4 key购买 nike

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

XAResourceProducer.setFailed介绍

[英]Mark this resource producer as failed or not. A resource is considered failed if recovery fails to run on it.
[中]将此资源生成器标记为失败或否。如果无法在资源上运行恢复,则认为该资源已失败。

代码示例

代码示例来源:origin: org.codehaus.btm/btm

/**
 * Recover all configured resources and fill the <code>recoveredXidSets</code> with all recovered XIDs.
 * Step 1.
 */
private void recoverAllResources() {
  // a cloned registeredResources Map must be iterated as the original one can be modified in the loop
  for (Map.Entry<String, XAResourceProducer> entry : new HashMap<String, XAResourceProducer>(registeredResources).entrySet()) {
    String uniqueName = entry.getKey();
    XAResourceProducer producer = entry.getValue();
    try {
      if (log.isDebugEnabled()) log.debug("performing recovery on " + uniqueName);
      Set<BitronixXid> xids = recover(producer);
      if (log.isDebugEnabled()) log.debug("recovered " + xids.size() + " XID(s) from resource " + uniqueName);
      recoveredXidSets.put(uniqueName, xids);
      producer.setFailed(false);
    } catch (XAException ex) {
      producer.setFailed(true);
      registeredResources.remove(uniqueName);
      String extraErrorDetails = TransactionManagerServices.getExceptionAnalyzer().extractExtraXAExceptionDetails(ex);
      log.warn("error running recovery on resource '" + uniqueName + "', resource marked as failed (background recoverer will retry recovery)" +
          " (error=" + Decoder.decodeXAExceptionErrorCode(ex) + ")" + (extraErrorDetails == null ? "" : ", extra error=" + extraErrorDetails), ex);
    } catch (Exception ex) {
      producer.setFailed(true);
      registeredResources.remove(uniqueName);
      log.warn("error running recovery on resource '" + uniqueName + "', resource marked as failed (background recoverer will retry recovery)", ex);
    }
  }
}

代码示例来源:origin: bitronix/btm

/**
 * Recover all configured resources and fill the <code>recoveredXidSets</code> with all recovered XIDs.
 * Step 1.
 */
private void recoverAllResources() {
  // a cloned registeredResources Map must be iterated as the original one can be modified in the loop
  for (Map.Entry<String, XAResourceProducer> entry : new HashMap<String, XAResourceProducer>(registeredResources).entrySet()) {
    String uniqueName = entry.getKey();
    XAResourceProducer producer = entry.getValue();
    try {
      if (log.isDebugEnabled()) { log.debug("performing recovery on " + uniqueName); }
      Set<BitronixXid> xids = recover(producer);
      if (log.isDebugEnabled()) { log.debug("recovered " + xids.size() + " XID(s) from resource " + uniqueName); }
      recoveredXidSets.put(uniqueName, xids);
      producer.setFailed(false);
    } catch (XAException ex) {
      producer.setFailed(true);
      registeredResources.remove(uniqueName);
      String extraErrorDetails = TransactionManagerServices.getExceptionAnalyzer().extractExtraXAExceptionDetails(ex);
      log.warn("error running recovery on resource '" + uniqueName + "', resource marked as failed (background recoverer will retry recovery)" +
          " (error=" + Decoder.decodeXAExceptionErrorCode(ex) + ")" + (extraErrorDetails == null ? "" : ", extra error=" + extraErrorDetails), ex);
    } catch (Exception ex) {
      producer.setFailed(true);
      registeredResources.remove(uniqueName);
      log.warn("error running recovery on resource '" + uniqueName + "', resource marked as failed (background recoverer will retry recovery)", ex);
    }
  }
}

代码示例来源:origin: org.mule.btm/mule-btm

/**
 * Recover all configured resources and fill the <code>recoveredXidSets</code> with all recovered XIDs.
 * Step 1.
 */
private void recoverAllResources() {
  // a cloned registeredResources Map must be iterated as the original one can be modified in the loop
  for (Map.Entry<String, XAResourceProducer> entry : new HashMap<String, XAResourceProducer>(registeredResources).entrySet()) {
    String uniqueName = entry.getKey();
    XAResourceProducer producer = entry.getValue();
    try {
      if (log.isDebugEnabled()) log.debug("performing recovery on " + uniqueName);
      Set<BitronixXid> xids = recover(producer);
      if (log.isDebugEnabled()) log.debug("recovered " + xids.size() + " XID(s) from resource " + uniqueName);
      recoveredXidSets.put(uniqueName, xids);
      producer.setFailed(false);
    } catch (XAException ex) {
      producer.setFailed(true);
      registeredResources.remove(uniqueName);
      String extraErrorDetails = TransactionManagerServices.getExceptionAnalyzer().extractExtraXAExceptionDetails(ex);
      log.warn("error running recovery on resource '" + uniqueName + "', resource marked as failed (background recoverer will retry recovery)" +
          " (error=" + Decoder.decodeXAExceptionErrorCode(ex) + ")" + (extraErrorDetails == null ? "" : ", extra error=" + extraErrorDetails), ex);
    } catch (Exception ex) {
      producer.setFailed(true);
      registeredResources.remove(uniqueName);
      log.warn("error running recovery on resource '" + uniqueName + "', resource marked as failed (background recoverer will retry recovery)", ex);
    }
  }
}

代码示例来源:origin: com.github.marcus-nl.btm/btm

/**
 * Recover all configured resources and fill the <code>recoveredXidSets</code> with all recovered XIDs.
 * Step 1.
 */
private void recoverAllResources() {
  // a cloned registeredResources Map must be iterated as the original one can be modified in the loop
  for (Map.Entry<String, XAResourceProducer> entry : new HashMap<String, XAResourceProducer>(registeredResources).entrySet()) {
    String uniqueName = entry.getKey();
    XAResourceProducer producer = entry.getValue();
    try {
      if (log.isDebugEnabled()) { log.debug("performing recovery on " + uniqueName); }
      Set<BitronixXid> xids = recover(producer);
      if (log.isDebugEnabled()) { log.debug("recovered " + xids.size() + " XID(s) from resource " + uniqueName); }
      recoveredXidSets.put(uniqueName, xids);
      producer.setFailed(false);
    } catch (XAException ex) {
      producer.setFailed(true);
      registeredResources.remove(uniqueName);
      String extraErrorDetails = TransactionManagerServices.getExceptionAnalyzer().extractExtraXAExceptionDetails(ex);
      log.warn("error running recovery on resource '" + uniqueName + "', resource marked as failed (background recoverer will retry recovery)" +
          " (error=" + Decoder.decodeXAExceptionErrorCode(ex) + ")" + (extraErrorDetails == null ? "" : ", extra error=" + extraErrorDetails), ex);
    } catch (Exception ex) {
      producer.setFailed(true);
      registeredResources.remove(uniqueName);
      log.warn("error running recovery on resource '" + uniqueName + "', resource marked as failed (background recoverer will retry recovery)", ex);
    }
  }
}

代码示例来源:origin: org.codehaus.btm/com.springsource.org.codehaus.btm

xarhs = xaResourceProducer.startRecovery();
} catch (RecoveryException ex) {
  xaResourceProducer.setFailed(true);
  throw ex;
    throw new RecoveryException("error recovering resource '" + uniqueName + "' due to an imcompatible heuristic decision");
  xaResourceProducer.setFailed(false);
  xaResourceProducer.setFailed(true);
  throw new RecoveryException("failed recovering resource " + uniqueName, ex);
} catch (IOException ex) {
  xaResourceProducer.setFailed(true);
  throw new RecoveryException("failed recovering resource " + uniqueName, ex);
} catch (RuntimeException ex) {
  xaResourceProducer.setFailed(true);
  throw new RecoveryException("failed recovering resource " + uniqueName, ex);
} finally {

代码示例来源:origin: bitronix/btm

throw new RecoveryException("error recovering resource '" + uniqueName + "' due to an incompatible heuristic decision");
  xaResourceProducer.setFailed(false);
  xaResourceProducer.setFailed(true);
  throw new RecoveryException("failed recovering resource " + uniqueName, ex);
} catch (IOException ex) {
  xaResourceProducer.setFailed(true);
  throw new RecoveryException("failed recovering resource " + uniqueName, ex);
} catch (RuntimeException ex) {
  xaResourceProducer.setFailed(true);
  throw new RecoveryException("failed recovering resource " + uniqueName, ex);
} catch (RecoveryException ex) {
  xaResourceProducer.setFailed(true);
  throw ex;
} finally {

代码示例来源:origin: com.github.marcus-nl.btm/btm

throw new RecoveryException("error recovering resource '" + uniqueName + "' due to an incompatible heuristic decision");
  xaResourceProducer.setFailed(false);
  xaResourceProducer.setFailed(true);
  throw new RecoveryException("failed recovering resource " + uniqueName, ex);
} catch (IOException ex) {
  xaResourceProducer.setFailed(true);
  throw new RecoveryException("failed recovering resource " + uniqueName, ex);
} catch (RuntimeException ex) {
  xaResourceProducer.setFailed(true);
  throw new RecoveryException("failed recovering resource " + uniqueName, ex);
} catch (RecoveryException ex) {
  xaResourceProducer.setFailed(true);
  throw ex;
} finally {

代码示例来源:origin: org.codehaus.btm/btm

throw new RecoveryException("error recovering resource '" + uniqueName + "' due to an incompatible heuristic decision");
  xaResourceProducer.setFailed(false);
  xaResourceProducer.setFailed(true);
  throw new RecoveryException("failed recovering resource " + uniqueName, ex);
} catch (IOException ex) {
  xaResourceProducer.setFailed(true);
  throw new RecoveryException("failed recovering resource " + uniqueName, ex);
} catch (RuntimeException ex) {
  xaResourceProducer.setFailed(true);
  throw new RecoveryException("failed recovering resource " + uniqueName, ex);
} catch (RecoveryException ex) {
  xaResourceProducer.setFailed(true);
  throw ex;
} finally {

代码示例来源:origin: org.mule.btm/mule-btm

throw new RecoveryException("error recovering resource '" + uniqueName + "' due to an incompatible heuristic decision");
  xaResourceProducer.setFailed(false);
  xaResourceProducer.setFailed(true);
  throw new RecoveryException("failed recovering resource " + uniqueName, ex);
} catch (IOException ex) {
  xaResourceProducer.setFailed(true);
  throw new RecoveryException("failed recovering resource " + uniqueName, ex);
} catch (RuntimeException ex) {
  xaResourceProducer.setFailed(true);
  throw new RecoveryException("failed recovering resource " + uniqueName, ex);
} catch (RecoveryException ex) {
  xaResourceProducer.setFailed(true);
  throw ex;
} finally {

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