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

XAResourceHolderState.isEnded介绍

暂无

代码示例

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

/**
 * Suspend all enlisted resources from the current transaction context.
 * @throws XAException if the resource threw an exception during suspend.
 */
public void suspend() throws XAException {
  for (XAResourceHolderState xaResourceHolderState : resources) {
    if (!xaResourceHolderState.isEnded()) {
      if (log.isDebugEnabled()) { log.debug("suspending " + xaResourceHolderState); }
      xaResourceHolderState.end(XAResource.TMSUCCESS);
    }
  } // while
}

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

/**
 * Suspend all enlisted resources from the current transaction context.
 * @throws XAException if the resource threw an exception during suspend.
 */
public void suspend() throws XAException {
  for (XAResourceHolderState xaResourceHolderState : resources) {
    if (!xaResourceHolderState.isEnded()) {
      if (log.isDebugEnabled()) { log.debug("suspending " + xaResourceHolderState); }
      xaResourceHolderState.end(XAResource.TMSUCCESS);
    }
  } // while
}

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

/**
 * Suspend all enlisted resources from the current transaction context.
 * @throws XAException if the resource threw an exception during suspend.
 */
public void suspend() throws XAException {
  for (XAResourceHolderState xaResourceHolderState : resources) {
    if (!xaResourceHolderState.isEnded()) {
      if (log.isDebugEnabled()) log.debug("suspending " + xaResourceHolderState);
      xaResourceHolderState.end(XAResource.TMSUCCESS);
    }
  } // while
}

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

/**
 * Suspend all enlisted resources from the current transaction context.
 * @throws XAException if the resource threw an exception during suspend.
 */
public void suspend() throws XAException {
  for (XAResourceHolderState xaResourceHolderState : resources) {
    if (!xaResourceHolderState.isEnded()) {
      if (log.isDebugEnabled()) log.debug("suspending " + xaResourceHolderState);
      xaResourceHolderState.end(XAResource.TMSUCCESS);
    }
  } // while
}

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

/**
 * Search for an eventually already enlisted {@link XAResourceHolderState} that could be joined with the
 * {@link XAResourceHolderState} passed as parameter.<br/>
 * If datasource configuration property <code>bitronix.useTmJoin=false</code> is set this method always returns null.
 * @param xaResourceHolderState a {@link XAResourceHolderState} looking to be joined.
 * @return another enlisted {@link XAResourceHolderState} that can be joined with the one passed in or null if none is found.
 * @throws XAException if call to XAResource.isSameRM() fails.
 */
private XAResourceHolderState getManagedResourceWithSameRM(XAResourceHolderState xaResourceHolderState) throws XAException {
  if (!xaResourceHolderState.getUseTmJoin()) {
    if (log.isDebugEnabled()) { log.debug("join disabled on resource " + xaResourceHolderState); }
    return null;
  }
  for (XAResourceHolderState alreadyEnlistedHolderState : resources) {
    if (log.isDebugEnabled())
      log.debug("checking joinability of " + xaResourceHolderState + " with " + alreadyEnlistedHolderState);
    if (alreadyEnlistedHolderState.isEnded() &&
        !alreadyEnlistedHolderState.isSuspended() &&
        xaResourceHolderState.getXAResource().isSameRM(alreadyEnlistedHolderState.getXAResource())) {
      if (log.isDebugEnabled()) { log.debug("resources are joinable"); }
      return alreadyEnlistedHolderState;
    }
    if (log.isDebugEnabled()) { log.debug("resources are not joinable"); }
  }
  if (log.isDebugEnabled()) { log.debug("no joinable resource found for " + xaResourceHolderState); }
  return null;
}

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

/**
 * Search for an eventually already enlisted {@link XAResourceHolderState} that could be joined with the
 * {@link XAResourceHolderState} passed as parameter.<br/>
 * If datasource configuration property <code>bitronix.useTmJoin=false</code> is set this method always returns null.
 * @param xaResourceHolderState a {@link XAResourceHolderState} looking to be joined.
 * @return another enlisted {@link XAResourceHolderState} that can be joined with the one passed in or null if none is found.
 * @throws XAException if call to XAResource.isSameRM() fails.
 */
private XAResourceHolderState getManagedResourceWithSameRM(XAResourceHolderState xaResourceHolderState) throws XAException {
  if (!xaResourceHolderState.getUseTmJoin()) {
    if (log.isDebugEnabled()) { log.debug("join disabled on resource " + xaResourceHolderState); }
    return null;
  }
  for (XAResourceHolderState alreadyEnlistedHolderState : resources) {
    if (log.isDebugEnabled())
      log.debug("checking joinability of " + xaResourceHolderState + " with " + alreadyEnlistedHolderState);
    if (alreadyEnlistedHolderState.isEnded() &&
        !alreadyEnlistedHolderState.isSuspended() &&
        xaResourceHolderState.getXAResource().isSameRM(alreadyEnlistedHolderState.getXAResource())) {
      if (log.isDebugEnabled()) { log.debug("resources are joinable"); }
      return alreadyEnlistedHolderState;
    }
    if (log.isDebugEnabled()) { log.debug("resources are not joinable"); }
  }
  if (log.isDebugEnabled()) { log.debug("no joinable resource found for " + xaResourceHolderState); }
  return null;
}

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

if (!resource.isEnded()) {
  if (log.isDebugEnabled()) log.debug("found unclosed resource to delist: " + resource);
  try {

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

if (!resource.isEnded()) {
  if (log.isDebugEnabled()) { log.debug("found unclosed resource to delist: " + resource); }
  try {

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

/**
 * Search for an eventually already enlisted {@link XAResourceHolderState} that could be joined with the
 * {@link XAResourceHolderState} passed as parameter.<br/>
 * If datasource configuration property <code>bitronix.useTmJoin=false</code> is set this method always returns null.
 * @param xaResourceHolderState a {@link XAResourceHolderState} looking to be joined.
 * @return another enlisted {@link XAResourceHolderState} that can be joined with the one passed in or null if none is found.
 * @throws XAException if call to XAResource.isSameRM() fails.
 */
private XAResourceHolderState getManagedResourceWithSameRM(XAResourceHolderState xaResourceHolderState) throws XAException {
  if (!xaResourceHolderState.getUseTmJoin()) {
    if (log.isDebugEnabled()) log.debug("join disabled on resource " + xaResourceHolderState);
    return null;
  }
  for (XAResourceHolderState alreadyEnlistedHolderState : resources) {
    if (log.isDebugEnabled())
      log.debug("checking joinability of " + xaResourceHolderState + " with " + alreadyEnlistedHolderState);
    if (alreadyEnlistedHolderState.isEnded() &&
        !alreadyEnlistedHolderState.isSuspended() &&
        xaResourceHolderState.getXAResource().isSameRM(alreadyEnlistedHolderState.getXAResource())) {
      if (log.isDebugEnabled()) log.debug("resources are joinable");
      return alreadyEnlistedHolderState;
    }
    if (log.isDebugEnabled()) log.debug("resources are not joinable");
  }
  
  if (log.isDebugEnabled()) log.debug("no joinable resource found for " + xaResourceHolderState);
  return null;
}

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

/**
 * Search for an eventually already enlisted {@link XAResourceHolderState} that could be joined with the
 * {@link XAResourceHolderState} passed as parameter.<br/>
 * If datasource configuration property <code>bitronix.useTmJoin=false</code> is set this method always returns null.
 * @param xaResourceHolderState a {@link XAResourceHolderState} looking to be joined.
 * @return another enlisted {@link XAResourceHolderState} that can be joined with the one passed in or null if none is found.
 * @throws XAException if call to XAResource.isSameRM() fails.
 */
private XAResourceHolderState getManagedResourceWithSameRM(XAResourceHolderState xaResourceHolderState) throws XAException {
  if (!xaResourceHolderState.getUseTmJoin()) {
    if (log.isDebugEnabled()) log.debug("join disabled on resource " + xaResourceHolderState);
    return null;
  }
  for (XAResourceHolderState alreadyEnlistedHolderState : resources) {
    if (log.isDebugEnabled())
      log.debug("checking joinability of " + xaResourceHolderState + " with " + alreadyEnlistedHolderState);
    if (alreadyEnlistedHolderState.isEnded() &&
        !alreadyEnlistedHolderState.isSuspended() &&
        xaResourceHolderState.getXAResource().isSameRM(alreadyEnlistedHolderState.getXAResource())) {
      if (log.isDebugEnabled()) log.debug("resources are joinable");
      return alreadyEnlistedHolderState;
    }
    if (log.isDebugEnabled()) log.debug("resources are not joinable");
  }
  
  if (log.isDebugEnabled()) log.debug("no joinable resource found for " + xaResourceHolderState);
  return null;
}

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

/**
 * If this method returns false, then local transaction calls like Connection.commit() can be made.
 * @return true if start() has been successfully called but not end() yet <i>and</i> the transaction is not suspended.
 */
public boolean isParticipatingInActiveGlobalTransaction() {
  rwLock.readLock().lock();
  try {
    BitronixTransaction currentTransaction = TransactionContextHelper.currentTransaction();
    Uid gtrid = currentTransaction == null ? null : currentTransaction.getResourceManager().getGtrid();
    if (gtrid == null)
      return false;
    Map<Uid, XAResourceHolderState> statesForGtrid = xaResourceHolderStates.get(gtrid);
    if (statesForGtrid == null)
      return false;
    for (XAResourceHolderState xaResourceHolderState : statesForGtrid.values()) {
      if (xaResourceHolderState != null &&
          xaResourceHolderState.isStarted() &&
          !xaResourceHolderState.isSuspended() &&
          !xaResourceHolderState.isEnded())
        return true;
    }
    return false;
  }
  finally {
    rwLock.readLock().unlock();
  }
}

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

/**
 * If this method returns false, then local transaction calls like Connection.commit() can be made.
 * @return true if start() has been successfully called but not end() yet <i>and</i> the transaction is not suspended.
 */
public boolean isParticipatingInActiveGlobalTransaction() {
  rwLock.readLock().lock();
  try {
    BitronixTransaction currentTransaction = TransactionContextHelper.currentTransaction();
    Uid gtrid = currentTransaction == null ? null : currentTransaction.getResourceManager().getGtrid();
    if (gtrid == null)
      return false;
    Map<Uid, XAResourceHolderState> statesForGtrid = xaResourceHolderStates.get(gtrid);
    if (statesForGtrid == null)
      return false;
    for (XAResourceHolderState xaResourceHolderState : statesForGtrid.values()) {
      if (xaResourceHolderState != null &&
          xaResourceHolderState.isStarted() &&
          !xaResourceHolderState.isSuspended() &&
          !xaResourceHolderState.isEnded())
        return true;
    }
    return false;
  }
  finally {
    rwLock.readLock().unlock();
  }
}

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

/**
 * Delist the {@link XAResourceHolder} from the current transaction or do nothing if there is no global transaction
 * context for this thread.
 * @param xaResourceHolder the {@link XAResourceHolder} to delist.
 * @throws SystemException if an internal error happens.
 */
public static void delistFromCurrentTransaction(XAResourceHolder xaResourceHolder) throws SystemException {
  BitronixTransaction currentTransaction = currentTransaction();
  ResourceBean bean = xaResourceHolder.getResourceBean();
  if (log.isDebugEnabled()) log.debug("delisting " + xaResourceHolder + " from " + currentTransaction);
  // End resource as eagerly as possible. This allows to release connections to the pool much earlier
  // with resources fully supporting transaction interleaving.
  if (isInEnlistingGlobalTransactionContext(xaResourceHolder, currentTransaction) && !bean.getDeferConnectionRelease()) {
    Map<Uid, XAResourceHolderState> statesForGtrid = xaResourceHolder.getXAResourceHolderStatesForGtrid(currentTransaction.getResourceManager().getGtrid());
    for (XAResourceHolderState xaResourceHolderState : statesForGtrid.values()) {
      if (!xaResourceHolderState.isEnded()) {
        if (log.isDebugEnabled())
          log.debug("delisting resource " + xaResourceHolderState + " from " + currentTransaction);
        // Watch out: the delistResource() call might throw a BitronixRollbackSystemException to indicate a unilateral rollback.
        currentTransaction.delistResource(xaResourceHolderState.getXAResource(), XAResource.TMSUCCESS);
      } else if (log.isDebugEnabled()) log.debug("avoiding delistment of not enlisted resource " + xaResourceHolderState);
    }
  } // isInEnlistingGlobalTransactionContext
}

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

/**
 * Delist the {@link XAResourceHolder} from the current transaction or do nothing if there is no global transaction
 * context for this thread.
 * @param xaResourceHolder the {@link XAResourceHolder} to delist.
 * @throws SystemException if an internal error happens.
 */
public static void delistFromCurrentTransaction(XAResourceHolder xaResourceHolder) throws SystemException {
  BitronixTransaction currentTransaction = currentTransaction();
  ResourceBean bean = xaResourceHolder.getResourceBean();
  if (log.isDebugEnabled()) log.debug("delisting " + xaResourceHolder + " from " + currentTransaction);
  // End resource as eagerly as possible. This allows to release connections to the pool much earlier
  // with resources fully supporting transaction interleaving.
  if (isInEnlistingGlobalTransactionContext(xaResourceHolder, currentTransaction) && !bean.getDeferConnectionRelease()) {
    Map<Uid, XAResourceHolderState> statesForGtrid = xaResourceHolder.getXAResourceHolderStatesForGtrid(currentTransaction.getResourceManager().getGtrid());
    for (XAResourceHolderState xaResourceHolderState : statesForGtrid.values()) {
      if (!xaResourceHolderState.isEnded()) {
        if (log.isDebugEnabled())
          log.debug("delisting resource " + xaResourceHolderState + " from " + currentTransaction);
        // Watch out: the delistResource() call might throw a BitronixRollbackSystemException to indicate a unilateral rollback.
        currentTransaction.delistResource(xaResourceHolderState.getXAResource(), XAResource.TMSUCCESS);
      } else if (log.isDebugEnabled()) log.debug("avoiding delistment of not enlisted resource " + xaResourceHolderState);
    }
  } // isInEnlistingGlobalTransactionContext
}

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

/**
 * If this method returns false, then local transaction calls like Connection.commit() can be made.
 * @return true if start() has been successfully called but not end() yet <i>and</i> the transaction is not suspended.
 */
public boolean isParticipatingInActiveGlobalTransaction() {
  synchronized (xaResourceHolderStates) {
    BitronixTransaction currentTransaction = TransactionContextHelper.currentTransaction();
    Uid gtrid = currentTransaction == null ? null : currentTransaction.getResourceManager().getGtrid();
    if (gtrid == null)
      return false;
    Map<Uid, XAResourceHolderState> statesForGtrid = xaResourceHolderStates.get(gtrid);
    if (statesForGtrid == null)
      return false;
    for (XAResourceHolderState xaResourceHolderState : statesForGtrid.values()) {
      if (xaResourceHolderState != null &&
          xaResourceHolderState.isStarted() &&
          !xaResourceHolderState.isSuspended() &&
          !xaResourceHolderState.isEnded())
        return true;
    }
    return false;
  }
}

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

/**
 * If this method returns false, then local transaction calls like Connection.commit() can be made.
 * @return true if start() has been successfully called but not end() yet <i>and</i> the transaction is not suspended.
 */
public boolean isParticipatingInActiveGlobalTransaction() {
  synchronized (xaResourceHolderStates) {
    BitronixTransaction currentTransaction = TransactionContextHelper.currentTransaction();
    Uid gtrid = currentTransaction == null ? null : currentTransaction.getResourceManager().getGtrid();
    if (gtrid == null)
      return false;
    Map<Uid, XAResourceHolderState> statesForGtrid = xaResourceHolderStates.get(gtrid);
    if (statesForGtrid == null)
      return false;
    for (XAResourceHolderState xaResourceHolderState : statesForGtrid.values()) {
      if (xaResourceHolderState != null &&
          xaResourceHolderState.isStarted() &&
          !xaResourceHolderState.isSuspended() &&
          !xaResourceHolderState.isEnded())
        return true;
    }
    return false;
  }
}

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

if (alreadyEnlistedXAResourceHolderState == null || alreadyEnlistedXAResourceHolderState.isEnded()) {
  currentTransaction.enlistResource(xaResourceHolder.getXAResource());

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

if (alreadyEnlistedXAResourceHolderState == null || alreadyEnlistedXAResourceHolderState.isEnded()) {
  currentTransaction.enlistResource(xaResourceHolder.getXAResource());

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

if (alreadyEnlistedXAResourceHolderState == null || alreadyEnlistedXAResourceHolderState.isEnded()) {
  currentTransaction.enlistResource(xaResourceHolder.getXAResource());

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

if (alreadyEnlistedXAResourceHolderState == null || alreadyEnlistedXAResourceHolderState.isEnded()) {
  currentTransaction.enlistResource(xaResourceHolder.getXAResource());