org.bytesoft.transaction.supports.serialize.XAResourceDeserializer.deserialize()方法的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(10.9k)|赞(0)|评价(0)|浏览(76)

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

XAResourceDeserializer.deserialize介绍

暂无

代码示例

代码示例来源：origin: liuyangming/ByteTCC

private void cleanup(String resourceId, List<Xid> xidList) throws RuntimeException {
  XAResourceDeserializer resourceDeserializer = this.beanFactory.getResourceDeserializer();
  if (StringUtils.isBlank(resourceId)) {
    throw new IllegalStateException();
  }
  Xid[] xidArray = new Xid[xidList.size()];
  xidList.toArray(xidArray);
  LocalXAResourceDescriptor descriptor = //
      (LocalXAResourceDescriptor) resourceDeserializer.deserialize(resourceId);
  RecoveredResource resource = (RecoveredResource) descriptor.getDelegate();
  try {
    resource.forget(xidArray);
  } catch (XAException xaex) {
    logger.error("Error occurred while forgetting resource: {}.", resourceId, xaex);
    switch (xaex.errorCode) {
    case XAException.XAER_NOTA:
      break;
    case XAException.XAER_RMERR:
    case XAException.XAER_RMFAIL:
      throw new IllegalStateException();
    }
  }
}

代码示例来源：origin: liuyangming/ByteTCC

private void cleanupByResource(String resourceId, List<Xid> xidList) throws RuntimeException {
  XAResourceDeserializer resourceDeserializer = this.beanFactory.getResourceDeserializer();
  if (StringUtils.isBlank(resourceId)) {
    throw new IllegalStateException();
  }
  Xid[] xidArray = new Xid[xidList.size()];
  xidList.toArray(xidArray);
  LocalXAResourceDescriptor descriptor = //
      (LocalXAResourceDescriptor) resourceDeserializer.deserialize(resourceId);
  RecoveredResource resource = (RecoveredResource) descriptor.getDelegate();
  try {
    resource.forget(xidArray);
  } catch (XAException xaex) {
    logger.error("Error occurred while forgetting resource: {}.", resourceId, xaex);
    switch (xaex.errorCode) {
    case XAException.XAER_NOTA:
      break;
    case XAException.XAER_RMERR:
    case XAException.XAER_RMFAIL:
      throw new IllegalStateException();
    }
  }
}

代码示例来源：origin: liuyangming/ByteTCC

try {
      (LocalXAResourceDescriptor) resourceDeserializer.deserialize(recordKey.resource);
  RecoveredResource resource = (RecoveredResource) descriptor.getDelegate();
  resource.recoverable(transactionXid);

代码示例来源：origin: liuyangming/ByteTCC

if (resourceType == 0x01) {
  archive.setIdentified(true);
  descriptor = deserializer.deserialize(identifier);
} else if (resourceType == 0x02) {
  archive.setIdentified(true);
  descriptor = deserializer.deserialize(identifier);
} else if (resourceType == 0x03) {
  archive.setIdentified(true);
  descriptor = deserializer.deserialize(identifier);
} else {
  descriptor = new UnidentifiedResourceDescriptor();

代码示例来源：origin: liuyangming/ByteTCC

public XAResourceDescriptor deserialize(String identifier) {
  XAResourceDescriptor resourceDescriptor = this.resourceDeserializer.deserialize(identifier);
  if (resourceDescriptor != null) {
    return resourceDescriptor;
  }
  Matcher matcher = pattern.matcher(identifier);
  if (matcher.find()) {
    RemoteCoordinatorRegistry registry = RemoteCoordinatorRegistry.getInstance();
    String application = CommonUtils.getApplication(identifier);
    RemoteCoordinator participant = registry.getParticipant(application);
    if (participant == null) {
      RemoteAddr remoteAddr = CommonUtils.getRemoteAddr(identifier);
      RemoteNode remoteNode = CommonUtils.getRemoteNode(identifier);
      this.initializeRemoteParticipantIfNecessary(application);
      registry.putRemoteNode(remoteAddr, remoteNode);
    }
    RemoteResourceDescriptor descriptor = new RemoteResourceDescriptor();
    descriptor.setIdentifier(identifier);
    descriptor.setDelegate(registry.getParticipant(application));
    return descriptor;
  } else {
    logger.error("can not find a matching xa-resource(identifier= {})!", identifier);
    return null;
  }
}

代码示例来源：origin: liuyangming/ByteTCC

public XAResourceDescriptor deserialize(String identifier) {
  XAResourceDescriptor resourceDescriptor = this.resourceDeserializer.deserialize(identifier);
  if (resourceDescriptor != null) {
    return resourceDescriptor;
  }
  Matcher matcher = pattern.matcher(identifier);
  if (matcher.find() == false) {
    logger.error("can not find a matching xa-resource(identifier= {})!", identifier);
    return null;
  }
  RemoteCoordinatorRegistry registry = RemoteCoordinatorRegistry.getInstance();
  String application = CommonUtils.getApplication(identifier);
  if (registry.containsParticipant(application) == false) {
    SpringCloudCoordinator springCloudCoordinator = new SpringCloudCoordinator();
    springCloudCoordinator.setIdentifier(identifier);
    springCloudCoordinator.setEnvironment(this.environment);
    springCloudCoordinator.setStatefully(this.statefully);
    RemoteCoordinator participant = (RemoteCoordinator) Proxy.newProxyInstance(
        SpringCloudCoordinator.class.getClassLoader(), new Class[] { RemoteCoordinator.class },
        springCloudCoordinator);
    RemoteAddr remoteAddr = CommonUtils.getRemoteAddr(identifier);
    RemoteNode remoteNode = CommonUtils.getRemoteNode(identifier);
    registry.putParticipant(application, participant);
    registry.putRemoteNode(remoteAddr, remoteNode);
  }
  RemoteResourceDescriptor descriptor = new RemoteResourceDescriptor();
  descriptor.setIdentifier(identifier);
  descriptor.setDelegate(registry.getParticipant(application));
  return descriptor;
}

代码示例来源：origin: liuyangming/ByteTCC

public XAResourceDescriptor deserialize(String identifier) {
  XAResourceDescriptor resourceDescriptor = this.resourceDeserializer.deserialize(identifier);
  if (resourceDescriptor != null) {
    return resourceDescriptor;
  }
  Matcher matcher = pattern.matcher(identifier);
  if (matcher.find() == false) {
    logger.error("can not find a matching xa-resource(identifier= {})!", identifier);
    return null;
  }
  RemoteCoordinatorRegistry registry = RemoteCoordinatorRegistry.getInstance();
  String application = CommonUtils.getApplication(identifier);
  if (registry.containsParticipant(application) == false) {
    SpringBootCoordinator springCloudCoordinator = new SpringBootCoordinator();
    springCloudCoordinator.setIdentifier(identifier);
    springCloudCoordinator.setEnvironment(this.environment);
    RemoteCoordinator participant = (RemoteCoordinator) Proxy.newProxyInstance(
        SpringBootCoordinator.class.getClassLoader(), new Class[] { RemoteCoordinator.class },
        springCloudCoordinator);
    RemoteAddr remoteAddr = CommonUtils.getRemoteAddr(identifier);
    RemoteNode remoteNode = CommonUtils.getRemoteNode(identifier);
    registry.putParticipant(application, participant);
    registry.putPhysicalInstance(remoteAddr, participant);
    registry.putRemoteNode(remoteAddr, remoteNode);
  }
  RemoteResourceDescriptor descriptor = new RemoteResourceDescriptor();
  descriptor.setIdentifier(identifier);
  descriptor.setDelegate(registry.getParticipant(application));
  return descriptor;
}

代码示例来源：origin: liuyangming/ByteTCC

XAResourceDescriptor descriptor = resourceDeserializer.deserialize(identifier);
if (descriptor != null //
    && descriptor.getClass().getName().equals(descriptorType) == false) {

代码示例来源：origin: liuyangming/ByteTCC

XAResourceDescriptor descriptor = resourceDeserializer.deserialize(identifier);
RecoveredResource resource = (RecoveredResource) descriptor.getDelegate();
resource.recoverable(current.getCompensableXid());

代码示例来源：origin: org.bytesoft/bytetcc-core

private void cleanup(String resourceId, List<Xid> xidList) throws RuntimeException {
  XAResourceDeserializer resourceDeserializer = this.beanFactory.getResourceDeserializer();
  if (StringUtils.isBlank(resourceId)) {
    throw new IllegalStateException();
  }
  Xid[] xidArray = new Xid[xidList.size()];
  xidList.toArray(xidArray);
  LocalXAResourceDescriptor descriptor = //
      (LocalXAResourceDescriptor) resourceDeserializer.deserialize(resourceId);
  RecoveredResource resource = (RecoveredResource) descriptor.getDelegate();
  try {
    resource.forget(xidArray);
  } catch (XAException xaex) {
    logger.error("Error occurred while forgetting resource: {}.", resourceId, xaex);
    switch (xaex.errorCode) {
    case XAException.XAER_NOTA:
      break;
    case XAException.XAER_RMERR:
    case XAException.XAER_RMFAIL:
      throw new IllegalStateException();
    }
  }
}

代码示例来源：origin: org.bytesoft/bytetcc-core

try {
      (LocalXAResourceDescriptor) resourceDeserializer.deserialize(recordKey.resource);
  RecoveredResource resource = (RecoveredResource) descriptor.getDelegate();
  resource.recoverable(transactionXid);

代码示例来源：origin: org.bytesoft/bytetcc-core

if (resourceType == 0x01) {
  archive.setIdentified(true);
  descriptor = deserializer.deserialize(identifier);
} else if (resourceType == 0x02) {
  archive.setIdentified(true);
  descriptor = deserializer.deserialize(identifier);
} else if (resourceType == 0x03) {
  archive.setIdentified(true);
  descriptor = deserializer.deserialize(identifier);
} else {
  descriptor = new UnidentifiedResourceDescriptor();

代码示例来源：origin: org.bytesoft/bytejta-core

if (resourceType == 0x01) {
  archive.setIdentified(true);
  descriptor = deserializer.deserialize(identifier);
} else if (resourceType == 0x02) {
  archive.setIdentified(true);
  descriptor = deserializer.deserialize(identifier);
} else if (resourceType == 0x03) {
  archive.setIdentified(true);
  descriptor = deserializer.deserialize(identifier);
} else {
  descriptor = new UnidentifiedResourceDescriptor();

代码示例来源：origin: liuyangming/ByteJTA

if (resourceType == 0x01) {
  archive.setIdentified(true);
  descriptor = deserializer.deserialize(identifier);
} else if (resourceType == 0x02) {
  archive.setIdentified(true);
  descriptor = deserializer.deserialize(identifier);
} else if (resourceType == 0x03) {
  archive.setIdentified(true);
  descriptor = deserializer.deserialize(identifier);
} else {
  descriptor = new UnidentifiedResourceDescriptor();

代码示例来源：origin: liuyangming/ByteJTA

public XAResourceDescriptor deserialize(String identifier) {
  XAResourceDescriptor resourceDescriptor = this.resourceDeserializer.deserialize(identifier);
  if (resourceDescriptor != null) {
    return resourceDescriptor;
  }
  Matcher matcher = pattern.matcher(identifier);
  if (matcher.find()) {
    RemoteCoordinatorRegistry registry = RemoteCoordinatorRegistry.getInstance();
    String application = CommonUtils.getApplication(identifier);
    RemoteCoordinator participant = StringUtils.isBlank(application) ? null : registry.getParticipant(application);
    if (participant == null) {
      RemoteAddr remoteAddr = CommonUtils.getRemoteAddr(identifier);
      RemoteNode remoteNode = CommonUtils.getRemoteNode(identifier);
      this.initializeRemoteParticipantIfNecessary(application);
      registry.putRemoteNode(remoteAddr, remoteNode);
    }
    RemoteResourceDescriptor descriptor = new RemoteResourceDescriptor();
    descriptor.setIdentifier(identifier);
    descriptor.setDelegate(registry.getParticipant(application));
    return descriptor;
  } else {
    logger.error("can not find a matching xa-resource(identifier= {})!", identifier);
    return null;
  }
}

代码示例来源：origin: liuyangming/ByteJTA

public XAResourceDescriptor deserialize(String identifier) {
  XAResourceDescriptor resourceDescriptor = this.resourceDeserializer.deserialize(identifier);
  if (resourceDescriptor != null) {
    return resourceDescriptor;

代码示例来源：origin: org.bytesoft/bytejta-supports-dubbo

public XAResourceDescriptor deserialize(String identifier) {
  XAResourceDescriptor resourceDescriptor = this.resourceDeserializer.deserialize(identifier);
  if (resourceDescriptor != null) {
    return resourceDescriptor;

代码示例来源：origin: org.bytesoft/bytetcc-core

XAResourceDescriptor descriptor = resourceDeserializer.deserialize(identifier);
RecoveredResource resource = (RecoveredResource) descriptor.getDelegate();
resource.recoverable(current.getCompensableXid());

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

XAResourceDeserializer

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    XAResourceDeserializer类方法

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