gpt4 book ai didi

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

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

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

XAResourceHolderState.getUseTmJoin介绍

暂无

代码示例

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

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