- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中org.bytesoft.transaction.xa.XidFactory.createBranchXid()
方法的一些代码示例,展示了XidFactory.createBranchXid()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。XidFactory.createBranchXid()
方法的具体详情如下:
包路径:org.bytesoft.transaction.xa.XidFactory
类名称:XidFactory
方法名:createBranchXid
暂无
代码示例来源:origin: liuyangming/ByteTCC
TransactionXid branchXid = xidFactory.createBranchXid(globalXid, branchByteArray);
String resourceId = StringUtils.trimToNull(new String(resourceByteArray));
代码示例来源:origin: liuyangming/ByteTCC
transactionXid = xidFactory.createBranchXid(transactionGlobalXid, transactionBranchQualifier);
compensableXid = xidFactory.createBranchXid(compensableGlobalXid, compensableBranchQualifier);
TransactionXid identifier = xidFactory.createBranchXid(globalXid, branchByteArray);
代码示例来源:origin: liuyangming/ByteTCC
TransactionXid branchXid = xidFactory.createBranchXid(globalXid, branch);
代码示例来源:origin: liuyangming/ByteTCC
buffer.get(branchQualifier);
XidFactory xidFactory = this.beanFactory.getCompensableXidFactory();
TransactionXid branchXid = xidFactory.createBranchXid(xid, branchQualifier);
archive.setXid(branchXid);
代码示例来源:origin: liuyangming/ByteTCC
public void registerCompensable(CompensableInvocation invocation) {
XidFactory xidFactory = this.beanFactory.getTransactionXidFactory();
invocation.setEnlisted(true);
CompensableArchive archive = new CompensableArchive();
TransactionXid globalXid = xidFactory.createGlobalXid(this.transactionContext.getXid().getGlobalTransactionId());
TransactionXid branchXid = xidFactory.createBranchXid(globalXid);
archive.setIdentifier(branchXid);
archive.setCompensable(invocation);
this.archiveList.add(archive);
this.currentArchiveList.add(archive);
logger.info("{}| register compensable service: {}.",
ByteUtils.byteArrayToString(this.transactionContext.getXid().getGlobalTransactionId()),
ByteUtils.byteArrayToString(archive.getIdentifier().getGlobalTransactionId()));
}
代码示例来源:origin: liuyangming/ByteTCC
public void onEnlistResource(Xid xid, XAResource xares) {
String resourceKey = null;
if (XAResourceDescriptor.class.isInstance(xares)) {
XAResourceDescriptor descriptor = (XAResourceDescriptor) xares;
resourceKey = descriptor.getIdentifier();
} else if (XAResourceArchive.class.isInstance(xares)) {
XAResourceArchive resourceArchive = (XAResourceArchive) xares;
XAResourceDescriptor descriptor = resourceArchive.getDescriptor();
resourceKey = descriptor == null ? null : descriptor.getIdentifier();
}
CompensableLogger compensableLogger = this.beanFactory.getCompensableLogger();
if (this.transactionContext.isCompensating()) {
// this.archive.setCompensableXid(xid); // preset the compensable-xid.
this.archive.setCompensableResourceKey(resourceKey);
compensableLogger.updateCompensable(this.archive);
} else {
for (int i = 0; i < this.currentArchiveList.size(); i++) {
CompensableArchive compensableArchive = this.currentArchiveList.get(i);
compensableArchive.setTransactionXid(xid);
compensableArchive.setTransactionResourceKey(resourceKey);
XidFactory transactionXidFactory = this.beanFactory.getTransactionXidFactory();
TransactionXid globalXid = transactionXidFactory.createGlobalXid(xid.getGlobalTransactionId());
TransactionXid branchXid = transactionXidFactory.createBranchXid(globalXid);
compensableArchive.setCompensableXid(branchXid); // preset the compensable-xid.
compensableLogger.createCompensable(compensableArchive);
}
}
}
代码示例来源:origin: liuyangming/ByteTCC
TransactionXid branchXid = xidFactory.createBranchXid(globalXid, branchByteArray);
String resourceId = StringUtils.trimToNull(new String(resourceByteArray));
代码示例来源:origin: liuyangming/ByteTCC
byte[] branchQualifier = ByteUtils.stringToByteArray(bxid);
TransactionXid globalId = compensableXidFactory.createGlobalXid(globalTransactionId);
TransactionXid branchId = compensableXidFactory.createBranchXid(globalId, branchQualifier);
participant.setXid(branchId);
代码示例来源:origin: liuyangming/ByteTCC
TransactionXid branchXid = xidFactory.createBranchXid(globalXid);
try {
descriptor.start(branchXid, XAResource.TMNOFLAGS);
代码示例来源:origin: liuyangming/ByteTCC
.createGlobalXid(ByteUtils.stringToByteArray(transactionGlobalId));
if (StringUtils.isNotBlank(transactionBranchId)) {
TransactionXid transactionBranchXid = transactionXidFactory.createBranchXid(transactionGlobalXid,
ByteUtils.stringToByteArray(transactionBranchId));
service.setTransactionXid(transactionBranchXid);
.createGlobalXid(ByteUtils.stringToByteArray(compensableGlobalId));
if (StringUtils.isNotBlank(compensableBranchId)) {
TransactionXid compensableBranchXid = transactionXidFactory.createBranchXid(compensableGlobalXid,
ByteUtils.stringToByteArray(compensableBranchId));
service.setCompensableXid(compensableBranchXid);
byte[] branchQualifier = ByteUtils.stringToByteArray(bxid);
TransactionXid globalId = transactionXidFactory.createGlobalXid(globalTransactionId);
TransactionXid branchId = transactionXidFactory.createBranchXid(globalId, branchQualifier);
service.setIdentifier(branchId);
代码示例来源:origin: org.bytesoft/bytetcc-core
TransactionXid branchXid = xidFactory.createBranchXid(globalXid, branchByteArray);
String resourceId = StringUtils.trimToNull(new String(resourceByteArray));
代码示例来源:origin: org.bytesoft/bytetcc-core
transactionXid = xidFactory.createBranchXid(transactionGlobalXid, transactionBranchQualifier);
compensableXid = xidFactory.createBranchXid(compensableGlobalXid, compensableBranchQualifier);
TransactionXid identifier = xidFactory.createBranchXid(globalXid, branchByteArray);
代码示例来源:origin: org.bytesoft/bytetcc-core
buffer.get(branchQualifier);
XidFactory xidFactory = this.beanFactory.getCompensableXidFactory();
TransactionXid branchXid = xidFactory.createBranchXid(xid, branchQualifier);
archive.setXid(branchXid);
代码示例来源:origin: org.bytesoft/bytejta-core
buffer.get(branchQualifier);
XidFactory xidFactory = this.beanFactory.getXidFactory();
TransactionXid branchXid = xidFactory.createBranchXid(xid, branchQualifier);
archive.setXid(branchXid);
代码示例来源:origin: liuyangming/ByteJTA
buffer.get(branchQualifier);
XidFactory xidFactory = this.beanFactory.getXidFactory();
TransactionXid branchXid = xidFactory.createBranchXid(xid, branchQualifier);
archive.setXid(branchXid);
代码示例来源:origin: org.bytesoft/bytetcc-core
public void registerCompensable(CompensableInvocation invocation) {
XidFactory xidFactory = this.beanFactory.getTransactionXidFactory();
invocation.setEnlisted(true);
CompensableArchive archive = new CompensableArchive();
TransactionXid globalXid = xidFactory.createGlobalXid(this.transactionContext.getXid().getGlobalTransactionId());
TransactionXid branchXid = xidFactory.createBranchXid(globalXid);
archive.setIdentifier(branchXid);
archive.setCompensable(invocation);
this.archiveList.add(archive);
this.currentArchiveList.add(archive);
logger.info("{}| register compensable service: {}.",
ByteUtils.byteArrayToString(this.transactionContext.getXid().getGlobalTransactionId()),
ByteUtils.byteArrayToString(archive.getIdentifier().getGlobalTransactionId()));
}
代码示例来源:origin: org.bytesoft/bytetcc-core
TransactionXid branchXid = xidFactory.createBranchXid(globalXid);
代码示例来源:origin: org.bytesoft/bytetcc-core
TransactionXid branchXid = xidFactory.createBranchXid(globalXid, branchByteArray);
String resourceId = StringUtils.trimToNull(new String(resourceByteArray));
代码示例来源:origin: org.bytesoft/bytejta-core
TransactionXid globalXid = this.transactionContext.getXid();
XidFactory xidFactory = this.beanFactory.getXidFactory();
archive.setXid(xidFactory.createBranchXid(globalXid));
} else {
flags = XAResource.TMJOIN;
代码示例来源:origin: liuyangming/ByteJTA
} else {
XidFactory xidFactory = this.beanFactory.getXidFactory();
archive.setXid(xidFactory.createBranchXid(this.transactionContext.getXid()));
本文整理了Java中org.bytesoft.transaction.xa.XidFactory类的一些代码示例,展示了XidFactory类的具体用法。这些代码示例主要来源于Github/Stack
本文整理了Java中org.bytesoft.transaction.supports.resource.XAResourceDescriptor类的一些代码示例,展示了XAResourceDescr
本文整理了Java中org.bytesoft.transaction.xa.XidFactory.createBranchXid()方法的一些代码示例,展示了XidFactory.createBran
本文整理了Java中org.bytesoft.transaction.xa.XidFactory.createGlobalXid()方法的一些代码示例,展示了XidFactory.createGlob
本文整理了Java中org.bytesoft.transaction.supports.resource.XAResourceDescriptor.getIdentifier()方法的一些代码示例,展
本文整理了Java中org.bytesoft.transaction.supports.resource.XAResourceDescriptor.getDelegate()方法的一些代码示例,展示了
我是一名优秀的程序员,十分优秀!