gpt4 book ai didi

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

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

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

XAResourceHolderState.isSuspended介绍

暂无

代码示例

代码示例来源: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: 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: 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: 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: 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: 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;
  }
}

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