javax.transaction.Transaction.delistResource()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(7.2k)|赞(0)|评价(0)|浏览(116)

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

Transaction.delistResource介绍

[英]Delist an XA resource from this transaction.
[中]从该事务中删除XA资源。

代码示例

代码示例来源：origin: spring-projects/spring-framework

@Override
public boolean delistResource(XAResource xaRes, int flag) throws SystemException {
  return this.transactionManager.getTransaction().delistResource(xaRes, flag);
}

代码示例来源：origin: apache/ignite

/** {@inheritDoc} */
@Override public boolean delistResource(XAResource xaRes, int flag) throws IllegalStateException,
  SystemException {
  return tx.delistResource(xaRes, flag);
}

代码示例来源：origin: org.springframework/spring-tx

@Override
public boolean delistResource(XAResource xaRes, int flag) throws SystemException {
  return this.transactionManager.getTransaction().delistResource(xaRes, flag);
}

代码示例来源：origin: wildfly/wildfly

public boolean delistResource(final XAResource xaRes, final int flag) throws IllegalStateException, SystemException {
  Assert.checkNotNullParam("xaRes", xaRes);
  return transaction.delistResource(xaRes, flag);
}

代码示例来源：origin: apache/geode

/**
 * Callback for Connection Closed.
 *
 * @param event ConnectionEvent Object.
 */
@Override
public void connectionClosed(ConnectionEvent event) {
 if (isActive) {
  ManagedConnection conn = (ManagedConnection) event.getSource();
  XAResource xar = null;
  if (xaResourcesMap.get(conn) != null)
   xar = (XAResource) xaResourcesMap.get(conn);
  xaResourcesMap.remove(conn);
  try {
   Transaction txn = transManager.getTransaction();
   if (txn != null && xar != null) {
    txn.delistResource(xar, XAResource.TMSUCCESS);
   }
  } catch (Exception se) {
   String exception =
     "JCAConnectionManagerImpl::connectionClosed: Exception occurred due to " + se;
   if (logger.isDebugEnabled()) {
    logger.debug(exception, se);
   }
  }
  mannPoolCache.returnPooledConnectionToPool(conn);
 }
}

代码示例来源：origin: apache/geode

/**
 * Implementation of call back function from ConnectionEventListener interface. This callback will
 * be invoked on connection close event.
 *
 * @param event Connection event object
 */
@Override
public void connectionClosed(ConnectionEvent event) {
 if (isActive) {
  try {
   XAConnection conn = (XAConnection) event.getSource();
   XAResource xar = (XAResource) xaResourcesMap.get(conn);
   xaResourcesMap.remove(conn);
   Transaction txn = transManager.getTransaction();
   if (txn != null && xar != null)
    txn.delistResource(xar, XAResource.TMSUCCESS);
   provider.returnConnection(conn);
  } catch (Exception e) {
   String exception =
     "GemFireTransactionDataSource::connectionClosed: Exception occurred due to " + e;
   if (logger.isDebugEnabled()) {
    logger.debug(exception, e);
   }
  }
 }
}

代码示例来源：origin: apache/geode

Transaction txn = transManager.getTransaction();
 if (txn != null && xar != null)
  txn.delistResource(xar, XAResource.TMSUCCESS);
} catch (SystemException se) {
 se.printStackTrace();

代码示例来源：origin: org.hibernate.ogm/hibernate-ogm-ignite

@Override
public boolean delistResource( final XAResource xaRes, final int flag ) throws IllegalStateException, SystemException {
  return delegate.delistResource( xaRes, flag );
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.spring-tx

@Override
public boolean delistResource(XAResource xaRes, int flag) throws SystemException {
  return this.transactionManager.getTransaction().delistResource(xaRes, flag);
}

代码示例来源：origin: org.onehippo.cms7/hippo-repository-connector

/**
 * @see javax.transaction.UserTransaction#rollback
 */
public void rollback() throws IllegalStateException, SecurityException, SystemException {
  int flag = XAResource.TMFAIL;
  tm.getTransaction().delistResource(XARes, flag);
  tm.rollback();
}

代码示例来源：origin: org.onehippo.cms7/hippo-repository-connector

/**
 * @see javax.transaction.UserTransaction#commit
 */
public void commit() throws HeuristicMixedException, HeuristicRollbackException, IllegalStateException,
    RollbackException, SecurityException, SystemException {
  int flag = XAResource.TMSUCCESS;
  tm.getTransaction().delistResource(XARes, flag);
  tm.commit();
}

代码示例来源：origin: com.caucho/resin

private void delist()
{
 if (_tm != null) {
  try {
   Transaction trans = _tm.getTransaction();
   if (trans != null)
    trans.delistResource(this, 0);
  } catch (Exception e) {
   throw new RuntimeException(e);
  }
 }
}

代码示例来源：origin: org.apache.openejb/openejb-core

@Override
public boolean delistResource(final XAResource xaResource, final int i) throws IllegalStateException, SystemException {
  final XAResource wrapper = xaResourceWrapper.wrap(xaResource, name);
  return transaction.delistResource(wrapper, i);
}

代码示例来源：origin: org.jboss.eap/wildfly-client-all

public boolean delistResource(final XAResource xaRes, final int flag) throws IllegalStateException, SystemException {
  Assert.checkNotNullParam("xaRes", xaRes);
  return transaction.delistResource(xaRes, flag);
}

代码示例来源：origin: org.apache.tomee/openejb-core

@Override
public boolean delistResource(final XAResource xaResource, final int i) throws IllegalStateException, SystemException {
  final XAResource wrapper = xaResourceWrapper.wrap(xaResource, name);
  return transaction.delistResource(wrapper, i);
}

代码示例来源：origin: org.apache.geronimo.ext.openejb/openejb-core

public boolean delistResource(XAResource xaResource, int i) throws IllegalStateException, SystemException {
  XAResource wrapper = xaResourceWrapper.wrap(xaResource, name);
  return transaction.delistResource(wrapper, i);
}

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

public boolean delistResource(XAResource resource, int tmflag) throws TransactionException {
 TransactionManager txManager = muleContext.getTransactionManager();
 try {
  Transaction jtaTransaction = txManager.getTransaction();
  if (jtaTransaction == null) {
   throw new TransactionException(CoreMessages.noJtaTransactionAvailable(Thread.currentThread()));
  }
  return jtaTransaction.delistResource(resource, tmflag);
 } catch (SystemException e) {
  throw new TransactionException(e);
 }
}

代码示例来源：origin: jbosstm/narayana

@Override
public void deregisterXAResource(XAResource xaResource) throws JMSException {
  try {
    if (!getTransaction().delistResource(xaResource, XAResource.TMSUCCESS)) {
      jtaLogger.i18NLogger.warn_failed_to_delist_xa_resource(null);
      throw getJmsException(jtaLogger.i18NLogger.get_failed_to_delist_xa_resource(), null);
    }
  } catch (IllegalStateException | SystemException e) {
    jtaLogger.i18NLogger.warn_failed_to_delist_xa_resource(e);
    throw getJmsException(jtaLogger.i18NLogger.get_failed_to_delist_xa_resource(), e);
  }
}

代码示例来源：origin: jbosstm/narayana

@Override
public void deregisterXAResource(XAResource xaResource) throws JMSException {
  try {
    if (!getTransaction().delistResource(xaResource, XAResource.TMSUCCESS)) {
      jtaLogger.i18NLogger.warn_failed_to_delist_xa_resource(null);
      throw getJmsException(jtaLogger.i18NLogger.get_failed_to_delist_xa_resource(), null);
    }
  } catch (IllegalStateException | SystemException e) {
    jtaLogger.i18NLogger.warn_failed_to_delist_xa_resource(e);
    throw getJmsException(jtaLogger.i18NLogger.get_failed_to_delist_xa_resource(), e);
  }
}

代码示例来源：origin: org.jboss.narayana.jts/narayana-jts-idlj

@Override
public void deregisterXAResource(XAResource xaResource) throws JMSException {
  try {
    if (!getTransaction().delistResource(xaResource, XAResource.TMSUCCESS)) {
      jtaLogger.i18NLogger.warn_failed_to_delist_xa_resource(null);
      throw getJmsException(jtaLogger.i18NLogger.get_failed_to_delist_xa_resource(), null);
    }
  } catch (IllegalStateException | SystemException e) {
    jtaLogger.i18NLogger.warn_failed_to_delist_xa_resource(e);
    throw getJmsException(jtaLogger.i18NLogger.get_failed_to_delist_xa_resource(), e);
  }
}

内容来源于网络，如有侵权，请联系作者删除！

Transaction

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com