gpt4 book ai didi

bitronix.tm.internal.XAResourceHolderState.getXid()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-25 18:31:05 27 4
gpt4 key购买 nike

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

XAResourceHolderState.getXid介绍

暂无

代码示例

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

private void commitResource(XAResourceHolderState resourceHolder, boolean onePhase) throws XAException {
  try {
    if (log.isDebugEnabled()) { log.debug("committing resource " + resourceHolder + (onePhase ? " (with one-phase optimization)" : "")); }
    resourceHolder.getXAResource().commit(resourceHolder.getXid(), onePhase);
    committedResources.add(resourceHolder);
    if (log.isDebugEnabled()) { log.debug("committed resource " + resourceHolder); }
  } catch (XAException ex) {
    handleXAException(resourceHolder, ex, onePhase);
  }
}

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

private void rollbackResource(XAResourceHolderState resourceHolder) throws XAException {
  try {
    if (log.isDebugEnabled()) { log.debug("trying to rollback resource " + resourceHolder); }
    resourceHolder.getXAResource().rollback(resourceHolder.getXid());
    rolledbackResources.add(resourceHolder);
    if (log.isDebugEnabled()) { log.debug("rolled back resource " + resourceHolder); }
  } catch (XAException ex) {
    handleXAException(resourceHolder, ex);
  }
}

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

private void commitResource(XAResourceHolderState resourceHolder, boolean onePhase) throws XAException {
  try {
    if (log.isDebugEnabled()) log.debug("committing resource " + resourceHolder + (onePhase ? " (with one-phase optimization)" : ""));
    resourceHolder.getXAResource().commit(resourceHolder.getXid(), onePhase);
    committedResources.add(resourceHolder);
    if (log.isDebugEnabled()) log.debug("committed resource " + resourceHolder);
  } catch (XAException ex) {
    handleXAException(resourceHolder, ex, onePhase);
  }
}

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

private void commitResource(XAResourceHolderState resourceHolder, boolean onePhase) throws XAException {
  try {
    if (log.isDebugEnabled()) { log.debug("committing resource " + resourceHolder + (onePhase ? " (with one-phase optimization)" : "")); }
    resourceHolder.getXAResource().commit(resourceHolder.getXid(), onePhase);
    committedResources.add(resourceHolder);
    if (log.isDebugEnabled()) { log.debug("committed resource " + resourceHolder); }
  } catch (XAException ex) {
    handleXAException(resourceHolder, ex, onePhase);
  }
}

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

private void rollbackResource(XAResourceHolderState resourceHolder) throws XAException {
  try {
    if (log.isDebugEnabled()) { log.debug("trying to rollback resource " + resourceHolder); }
    resourceHolder.getXAResource().rollback(resourceHolder.getXid());
    rolledbackResources.add(resourceHolder);
    if (log.isDebugEnabled()) { log.debug("rolled back resource " + resourceHolder); }
  } catch (XAException ex) {
    handleXAException(resourceHolder, ex);
  }
}

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

private void rollbackResource(XAResourceHolderState resourceHolder) throws XAException {
  try {
    if (log.isDebugEnabled()) log.debug("trying to rollback resource " + resourceHolder);
    resourceHolder.getXAResource().rollback(resourceHolder.getXid());
    rolledbackResources.add(resourceHolder);
    if (log.isDebugEnabled()) log.debug("rolled back resource " + resourceHolder);
  } catch (XAException ex) {
    handleXAException(resourceHolder, ex);
  }
}

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

private void rollbackResource(XAResourceHolderState resourceHolder) throws XAException {
  try {
    if (log.isDebugEnabled()) log.debug("trying to rollback resource " + resourceHolder);
    resourceHolder.getXAResource().rollback(resourceHolder.getXid());
    rolledbackResources.add(resourceHolder);
    if (log.isDebugEnabled()) log.debug("rolled back resource " + resourceHolder);
  } catch (XAException ex) {
    handleXAException(resourceHolder, ex);
  }
}

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

private void commitResource(XAResourceHolderState resourceHolder, boolean onePhase) throws XAException {
  try {
    if (log.isDebugEnabled()) log.debug("committing resource " + resourceHolder + (onePhase ? " (with one-phase optimization)" : ""));
    resourceHolder.getXAResource().commit(resourceHolder.getXid(), onePhase);
    committedResources.add(resourceHolder);
    if (log.isDebugEnabled()) log.debug("committed resource " + resourceHolder);
  } catch (XAException ex) {
    handleXAException(resourceHolder, ex, onePhase);
  }
}

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

/**
 * Log exceptions that happened during a phase failure.
 * @param ex the phase exception.
 */
protected void logFailedResources(PhaseException ex) {
  List<Exception> exceptions = ex.getExceptions();
  List<XAResourceHolderState> resources = ex.getResourceStates();
  for (int i = 0; i < exceptions.size(); i++) {
    Exception e = exceptions.get(i);
    XAResourceHolderState holderState = resources.get(i);
    log.error("resource " + holderState.getUniqueName() + " failed on " + holderState.getXid(), e);
  }
}

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

/**
 * Log exceptions that happened during a phase failure.
 * @param ex the phase exception.
 */
protected void logFailedResources(PhaseException ex) {
  List<Exception> exceptions = ex.getExceptions();
  List<XAResourceHolderState> resources = ex.getResourceStates();
  for (int i = 0; i < exceptions.size(); i++) {
    Exception e = exceptions.get(i);
    XAResourceHolderState holderState = resources.get(i);
    log.error("resource " + holderState.getUniqueName() + " failed on " + holderState.getXid(), e);
  }
}

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

public final void run() {
  String oldThreadName = null;
  if (TransactionManagerServices.getConfiguration().isAsynchronous2Pc()) {
    oldThreadName = Thread.currentThread().getName();
    Thread.currentThread().setName("bitronix-2pc [ " +
        resourceHolder.getXid().toString() +
        " ]");
  }
  execute();
  if (oldThreadName != null) {
    Thread.currentThread().setName(oldThreadName);
  }
}

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

public final void run() {
  String oldThreadName = null;
  if (TransactionManagerServices.getConfiguration().isAsynchronous2Pc()) {
    oldThreadName = Thread.currentThread().getName();
    Thread.currentThread().setName("bitronix-2pc [ " +
        resourceHolder.getXid().toString() +
        " ]");
  }
  execute();
  if (oldThreadName != null) {
    Thread.currentThread().setName(oldThreadName);
  }
}

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

private void forgetHeuristicCommit(XAResourceHolderState resourceHolder) {
  try {
    if (log.isDebugEnabled()) { log.debug("handling heuristic commit on resource " + resourceHolder.getXAResource()); }
    resourceHolder.getXAResource().forget(resourceHolder.getXid());
    if (log.isDebugEnabled()) { log.debug("forgotten heuristically committed resource " + resourceHolder.getXAResource()); }
  } catch (XAException ex) {
    String extraErrorDetails = TransactionManagerServices.getExceptionAnalyzer().extractExtraXAExceptionDetails(ex);
    log.error("cannot forget " + resourceHolder.getXid() + " assigned to " + resourceHolder.getXAResource() +
        ", error=" + Decoder.decodeXAExceptionErrorCode(ex) + (extraErrorDetails == null ? "" : ", extra error=" + extraErrorDetails), ex);
  }
}

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

private void forgetHeuristicCommit(XAResourceHolderState resourceHolder) {
  try {
    if (log.isDebugEnabled()) log.debug("handling heuristic commit on resource " + resourceHolder.getXAResource());
    resourceHolder.getXAResource().forget(resourceHolder.getXid());
    if (log.isDebugEnabled()) log.debug("forgotten heuristically committed resource " + resourceHolder.getXAResource());
  } catch (XAException ex) {
    String extraErrorDetails = TransactionManagerServices.getExceptionAnalyzer().extractExtraXAExceptionDetails(ex);
    log.error("cannot forget " + resourceHolder.getXid() + " assigned to " + resourceHolder.getXAResource() +
        ", error=" + Decoder.decodeXAExceptionErrorCode(ex) + (extraErrorDetails == null ? "" : ", extra error=" + extraErrorDetails), ex);
  }
}

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

private void forgetHeuristicRollback(XAResourceHolderState resourceHolder) {
  try {
    if (log.isDebugEnabled()) log.debug("handling heuristic rollback on resource " + resourceHolder.getXAResource());
    resourceHolder.getXAResource().forget(resourceHolder.getXid());
    if (log.isDebugEnabled()) log.debug("forgotten heuristically rolled back resource " + resourceHolder.getXAResource());
  } catch (XAException ex) {
    String extraErrorDetails = TransactionManagerServices.getExceptionAnalyzer().extractExtraXAExceptionDetails(ex);
    log.error("cannot forget " + resourceHolder.getXid() + " assigned to " + resourceHolder.getXAResource() +
        ", error=" + Decoder.decodeXAExceptionErrorCode(ex) + (extraErrorDetails == null ? "" : ", extra error=" + extraErrorDetails), ex);
  }
}

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

private void forgetHeuristicRollback(XAResourceHolderState resourceHolder) {
  try {
    if (log.isDebugEnabled()) { log.debug("handling heuristic rollback on resource " + resourceHolder.getXAResource()); }
    resourceHolder.getXAResource().forget(resourceHolder.getXid());
    if (log.isDebugEnabled()) { log.debug("forgotten heuristically rolled back resource " + resourceHolder.getXAResource()); }
  } catch (XAException ex) {
    String extraErrorDetails = TransactionManagerServices.getExceptionAnalyzer().extractExtraXAExceptionDetails(ex);
    log.error("cannot forget " + resourceHolder.getXid() + " assigned to " + resourceHolder.getXAResource() +
        ", error=" + Decoder.decodeXAExceptionErrorCode(ex) + (extraErrorDetails == null ? "" : ", extra error=" + extraErrorDetails), ex);
  }
}

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

private void forgetHeuristicRollback(XAResourceHolderState resourceHolder) {
  try {
    if (log.isDebugEnabled()) { log.debug("handling heuristic rollback on resource " + resourceHolder.getXAResource()); }
    resourceHolder.getXAResource().forget(resourceHolder.getXid());
    if (log.isDebugEnabled()) { log.debug("forgotten heuristically rolled back resource " + resourceHolder.getXAResource()); }
  } catch (XAException ex) {
    String extraErrorDetails = TransactionManagerServices.getExceptionAnalyzer().extractExtraXAExceptionDetails(ex);
    log.error("cannot forget " + resourceHolder.getXid() + " assigned to " + resourceHolder.getXAResource() +
        ", error=" + Decoder.decodeXAExceptionErrorCode(ex) + (extraErrorDetails == null ? "" : ", extra error=" + extraErrorDetails), ex);
  }
}

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

private void forgetHeuristicRollback(XAResourceHolderState resourceHolder) {
  try {
    if (log.isDebugEnabled()) log.debug("handling heuristic rollback on resource " + resourceHolder.getXAResource());
    resourceHolder.getXAResource().forget(resourceHolder.getXid());
    if (log.isDebugEnabled()) log.debug("forgotten heuristically rolled back resource " + resourceHolder.getXAResource());
  } catch (XAException ex) {
    String extraErrorDetails = TransactionManagerServices.getExceptionAnalyzer().extractExtraXAExceptionDetails(ex);
    log.error("cannot forget " + resourceHolder.getXid() + " assigned to " + resourceHolder.getXAResource() +
        ", error=" + Decoder.decodeXAExceptionErrorCode(ex) + (extraErrorDetails == null ? "" : ", extra error=" + extraErrorDetails), ex);
  }
}

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

private void forgetHeuristicCommit(XAResourceHolderState resourceHolder) {
  try {
    if (log.isDebugEnabled()) { log.debug("handling heuristic commit on resource " + resourceHolder.getXAResource()); }
    resourceHolder.getXAResource().forget(resourceHolder.getXid());
    if (log.isDebugEnabled()) { log.debug("forgotten heuristically committed resource " + resourceHolder.getXAResource()); }
  } catch (XAException ex) {
    String extraErrorDetails = TransactionManagerServices.getExceptionAnalyzer().extractExtraXAExceptionDetails(ex);
    log.error("cannot forget " + resourceHolder.getXid() + " assigned to " + resourceHolder.getXAResource() +
        ", error=" + Decoder.decodeXAExceptionErrorCode(ex) + (extraErrorDetails == null ? "" : ", extra error=" + extraErrorDetails), ex);
  }
}

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

private void forgetHeuristicCommit(XAResourceHolderState resourceHolder) {
  try {
    if (log.isDebugEnabled()) log.debug("handling heuristic commit on resource " + resourceHolder.getXAResource());
    resourceHolder.getXAResource().forget(resourceHolder.getXid());
    if (log.isDebugEnabled()) log.debug("forgotten heuristically committed resource " + resourceHolder.getXAResource());
  } catch (XAException ex) {
    String extraErrorDetails = TransactionManagerServices.getExceptionAnalyzer().extractExtraXAExceptionDetails(ex);
    log.error("cannot forget " + resourceHolder.getXid() + " assigned to " + resourceHolder.getXAResource() +
        ", error=" + Decoder.decodeXAExceptionErrorCode(ex) + (extraErrorDetails == null ? "" : ", extra error=" + extraErrorDetails), ex);
  }
}

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