- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中bitronix.tm.internal.XAResourceHolderState.isSuspended()
方法的一些代码示例,展示了XAResourceHolderState.isSuspended()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。XAResourceHolderState.isSuspended()
方法的具体详情如下:
包路径:bitronix.tm.internal.XAResourceHolderState
类名称: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;
}
}
本文整理了Java中bitronix.tm.internal.XAResourceHolderState类的一些代码示例,展示了XAResourceHolderState类的具体用法。这些代码示例主要
我的一个应用程序有问题。该应用程序是一个自行编写的 Java 应用程序,它通过 JMS 连接到 50 多个不同的消息队列并使用来自这些队列的消息。 从功能的角度来看,来自不同队列的所有消息的处理工作正
我正在尝试创建事务管理器并将其与 Hibernate for Oracle 一起使用。 我的 persistence.xml 文件是: org.hibernate.ejb.Hiber
我的目标是使用 Bitronix 交易,我应该使用两种资源: 数据库 JMS 我有以下java代码: package com.mycompany.app; import java.net.URI; i
您好,我有一个使用 spring 和 hibernate 的 Java web 应用程序。 我有一个名为Role 的模型类。对于所有模型类,都有通用的 GenericDao.java public i
本文整理了Java中bitronix.tm.internal.XAResourceHolderState.isFailed()方法的一些代码示例,展示了XAResourceHolderState.is
本文整理了Java中bitronix.tm.internal.XAResourceHolderState.getTwoPcOrderingPosition()方法的一些代码示例,展示了XAResour
本文整理了Java中bitronix.tm.internal.XAResourceHolderState.isSuspended()方法的一些代码示例,展示了XAResourceHolderState
本文整理了Java中bitronix.tm.internal.XAResourceHolderState.start()方法的一些代码示例,展示了XAResourceHolderState.start
本文整理了Java中bitronix.tm.internal.XAResourceHolderState.getXAResource()方法的一些代码示例,展示了XAResourceHolderSta
本文整理了Java中bitronix.tm.internal.XAResourceHolderState.getUseTmJoin()方法的一些代码示例,展示了XAResourceHolderStat
本文整理了Java中bitronix.tm.internal.XAResourceHolderState.setXid()方法的一些代码示例,展示了XAResourceHolderState.setX
本文整理了Java中bitronix.tm.internal.XAResourceHolderState.end()方法的一些代码示例,展示了XAResourceHolderState.end()的具
本文整理了Java中bitronix.tm.internal.XAResourceHolderState.setTransactionTimeoutDate()方法的一些代码示例,展示了XAResou
本文整理了Java中bitronix.tm.internal.XAResourceHolderState.getIgnoreRecoveryFailures()方法的一些代码示例,展示了XAResou
本文整理了Java中bitronix.tm.internal.XAResourceHolderState.isEnded()方法的一些代码示例,展示了XAResourceHolderState.isE
本文整理了Java中bitronix.tm.internal.XAResourceHolderState.getUniqueName()方法的一些代码示例,展示了XAResourceHolderSta
本文整理了Java中bitronix.tm.internal.XAResourceHolderState.getXid()方法的一些代码示例,展示了XAResourceHolderState.getX
本文整理了Java中bitronix.tm.internal.XAResourceHolderState.equals()方法的一些代码示例,展示了XAResourceHolderState.equa
本文整理了Java中bitronix.tm.internal.XAResourceHolderState.getXAResourceHolder()方法的一些代码示例,展示了XAResourceHol
我是一名优秀的程序员,十分优秀!