gpt4 book ai didi

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

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

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

XAResourceProducer.findXAResourceHolder介绍

[英]Find in the XAResourceHolders created by this XAResourceProducer the one which this XAResource belongs to.
[中]在该XAResourceProducer创建的XAResourceHolders中查找该XAResource所属的资源。

代码示例

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

/**
 * Find in the registered {@link XAResourceProducer}s the {@link XAResourceHolder} from which the specified {@link XAResource} comes from.
 * @param xaResource the {@link XAResource} to look for
 * @return the associated {@link XAResourceHolder} or null if it cannot be found.
 */
public static XAResourceHolder findXAResourceHolder(XAResource xaResource) {
  for (Map.Entry<String, XAResourceProducer> entry : resources.entrySet()) {
    XAResourceProducer producer = entry.getValue();
    XAResourceHolder resourceHolder = producer.findXAResourceHolder(xaResource);
    if (resourceHolder != null) {
      if (log.isDebugEnabled()) log.debug("XAResource " + xaResource + " belongs to " + resourceHolder + " that itself belongs to " + producer);
      return resourceHolder;
    }
    if (log.isDebugEnabled()) log.debug("XAResource " + xaResource + " does not belong to any resource of " + producer);
  }
  return null;
}

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

/**
 * Find in the registered {@link XAResourceProducer}s the {@link XAResourceHolder} from which the specified {@link XAResource} comes from.
 * @param xaResource the {@link XAResource} to look for
 * @return the associated {@link XAResourceHolder} or null if it cannot be found.
 */
public static XAResourceHolder findXAResourceHolder(XAResource xaResource) {
  for (Map.Entry<String, XAResourceProducer> entry : resources.entrySet()) {
    XAResourceProducer producer = entry.getValue();
    XAResourceHolder resourceHolder = producer.findXAResourceHolder(xaResource);
    if (resourceHolder != null) {
      if (log.isDebugEnabled()) log.debug("XAResource " + xaResource + " belongs to " + resourceHolder + " that itself belongs to " + producer);
      return resourceHolder;
    }
    if (log.isDebugEnabled()) log.debug("XAResource " + xaResource + " does not belong to any resource of " + producer);
  }
  return null;
}

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

/**
 * Find in the registered {@link XAResourceProducer}s the {@link XAResourceHolder} from which the specified {@link XAResource} comes from.
 *
 * @param xaResource the {@link XAResource} to look for
 * @return the associated {@link XAResourceHolder} or null if it cannot be found.
 */
public static XAResourceHolder findXAResourceHolder(XAResource xaResource) {
  final boolean debug = log.isDebugEnabled();
  for (ProducerHolder holder : resources) {
    if (!holder.isInitialized())
      continue;
    final XAResourceProducer producer = holder.producer;
    final XAResourceHolder resourceHolder = producer.findXAResourceHolder(xaResource);
    if (resourceHolder != null) {
      if (debug) { log.debug("XAResource " + xaResource + " belongs to " + resourceHolder + " that itself belongs to " + producer); }
      return resourceHolder;
    }
    if (debug) { log.debug("XAResource " + xaResource + " does not belong to any resource of " + producer); }
  }
  return null;
}

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

/**
 * Find in the registered {@link XAResourceProducer}s the {@link XAResourceHolder} from which the specified {@link XAResource} comes from.
 *
 * @param xaResource the {@link XAResource} to look for
 * @return the associated {@link XAResourceHolder} or null if it cannot be found.
 */
public static XAResourceHolder findXAResourceHolder(XAResource xaResource) {
  final boolean debug = log.isDebugEnabled();
  for (ProducerHolder holder : resources) {
    if (!holder.isInitialized())
      continue;
    final XAResourceProducer producer = holder.producer;
    final XAResourceHolder resourceHolder = producer.findXAResourceHolder(xaResource);
    if (resourceHolder != null) {
      if (debug) { log.debug("XAResource " + xaResource + " belongs to " + resourceHolder + " that itself belongs to " + producer); }
      return resourceHolder;
    }
    if (debug) { log.debug("XAResource " + xaResource + " does not belong to any resource of " + producer); }
  }
  return null;
}

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

@Test
  public void testFindXAResourceHolderDelegatesAndDoesNotCallUninitialized() throws Exception {
    final XAResource resource = mock(XAResource.class);
    final XAResourceProducer uninitializedProducer = createMockProducer("uninitialized");

    CountDownLatch border = new CountDownLatch(1);
    Future future = registerBlockingProducer(uninitializedProducer, border);

    ResourceRegistrar.findXAResourceHolder(resource);
    verify(producer, times(1)).findXAResourceHolder(resource);
    verify(uninitializedProducer, times(0)).findXAResourceHolder(resource);

    border.countDown();
    future.get();

    ResourceRegistrar.findXAResourceHolder(resource);
    verify(producer, times(2)).findXAResourceHolder(resource);
    verify(uninitializedProducer, times(1)).findXAResourceHolder(resource);
  }
}

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

@Test
  public void testFindXAResourceHolderDelegatesAndDoesNotCallUninitialized() throws Exception {
    final XAResource resource = mock(XAResource.class);
    final XAResourceProducer uninitializedProducer = createMockProducer("uninitialized");

    CountDownLatch border = new CountDownLatch(1);
    Future future = registerBlockingProducer(uninitializedProducer, border);

    ResourceRegistrar.findXAResourceHolder(resource);
    verify(producer, times(1)).findXAResourceHolder(resource);
    verify(uninitializedProducer, times(0)).findXAResourceHolder(resource);

    border.countDown();
    future.get();

    ResourceRegistrar.findXAResourceHolder(resource);
    verify(producer, times(2)).findXAResourceHolder(resource);
    verify(uninitializedProducer, times(1)).findXAResourceHolder(resource);
  }
}

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