org.apache.activemq.artemis.core.transaction.impl.XidImpl类的使用及代码示例

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

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

XidImpl介绍

[英]Xid implementation
[中]Xid实现

代码示例

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

  1. public static Xid decodeXid(final ActiveMQBuffer in) {
  2.  int formatID = in.readInt();
  3.  byte[] bq = new byte[in.readInt()];
  4.  in.readBytes(bq);
  5.  byte[] gtxid = new byte[in.readInt()];
  6.  in.readBytes(gtxid);
  7.  Xid xid = new XidImpl(bq, formatID, gtxid);
  8.  return xid;
  9. }

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

  1. @Override
  2. public String toString() {
  3.  return "XidImpl (" + System.identityHashCode(this) +
  4.    " bq:" +
  5.    stringRep(branchQualifier) +
  6.    " formatID:" +
  7.    formatId +
  8.    " gtxid:" +
  9.    stringRep(globalTransactionId) +
  10.    " base64:" + toBase64String(this);
  11. }

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

  1. @Override
  2. public int hashCode() {
  3.  if (!hashCalculated) {
  4.    calcHash();
  5.  }
  6.  return hash;
  7. }

代码示例来源：origin: apache/activemq-artemis

  1. @Override
  2. public String[] listPreparedTransactions() {
  3.  checkStarted();
  4.  clearIO();
  5.  try {
  6.    DateFormat dateFormat = DateFormat.getDateTimeInstance(DateFormat.SHORT, DateFormat.MEDIUM);
  7.    Map<Xid, Long> xids = resourceManager.getPreparedTransactionsWithCreationTime();
  8.    ArrayList<Entry<Xid, Long>> xidsSortedByCreationTime = new ArrayList<>(xids.entrySet());
  9.    Collections.sort(xidsSortedByCreationTime, new Comparator<Entry<Xid, Long>>() {
  10.     @Override
  11.     public int compare(final Entry<Xid, Long> entry1, final Entry<Xid, Long> entry2) {
  12.       // sort by creation time, oldest first
  13.       return (int) (entry1.getValue() - entry2.getValue());
  14.     }
  15.    });
  16.    String[] s = new String[xidsSortedByCreationTime.size()];
  17.    int i = 0;
  18.    for (Map.Entry<Xid, Long> entry : xidsSortedByCreationTime) {
  19.     Date creation = new Date(entry.getValue());
  20.     Xid xid = entry.getKey();
  21.     s[i++] = dateFormat.format(creation) + " base64: " + XidImpl.toBase64String(xid) + " " + xid.toString();
  22.    }
  23.    return s;
  24.  } finally {
  25.    blockOnIO();
  26.  }
  27. }

代码示例来源：origin: apache/activemq-artemis

  1. Xid xid = new XidImpl("xa1".getBytes(), 1, globalTransactionId);
  2. Xid xid2 = new XidImpl("xa2".getBytes(), 1, globalTransactionId);
  3. ServerLocator locator = createInVMNonHALocator();
  4. ClientSessionFactory csf = createSessionFactory(locator);
  5. receiveLocator.close();
  6. boolean success = serverControl.commitPreparedTransaction(XidImpl.toBase64String(xid));
  7. success = serverControl.commitPreparedTransaction(XidImpl.toBase64String(xid));

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

  1. private void calcHash() {
  2.  byte[] hashBytes = XidImpl.toByteArray(this);
  3.  hash = Arrays.hashCode(hashBytes);
  4.  hashCalculated = true;
  5. }

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

  1. /**
  2. * Copy constructor
  3. *
  4. * @param other
  5. */
  6. public XidImpl(final Xid other) {
  7.  branchQualifier = copyBytes(other.getBranchQualifier());
  8.  formatId = other.getFormatId();
  9.  globalTransactionId = copyBytes(other.getGlobalTransactionId());
  10. }

代码示例来源：origin: apache/activemq-artemis

  1. @Override
  2. public String[] listHeuristicCommittedTransactions() {
  3.  checkStarted();
  4.  clearIO();
  5.  try {
  6.    List<Xid> xids = resourceManager.getHeuristicCommittedTransactions();
  7.    String[] s = new String[xids.size()];
  8.    int i = 0;
  9.    for (Xid xid : xids) {
  10.     s[i++] = XidImpl.toBase64String(xid);
  11.    }
  12.    return s;
  13.  } finally {
  14.    blockOnIO();
  15.  }
  16. }

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

  1. public static String toBase64String(final Xid xid) {
  2.  byte[] data = XidImpl.toByteArray(xid);
  3.  return Base64.encodeBytes(data, 0, data.length, Base64.DONT_BREAK_LINES | Base64.URL_SAFE);
  4. }

代码示例来源：origin: apache/activemq-artemis

  1. /**
  2. * Copy constructor
  3. *
  4. * @param other
  5. */
  6. public XidImpl(final Xid other) {
  7.  branchQualifier = copyBytes(other.getBranchQualifier());
  8.  formatId = other.getFormatId();
  9.  globalTransactionId = copyBytes(other.getGlobalTransactionId());
  10. }

代码示例来源：origin: apache/activemq-artemis

  1. protected XidImpl newXID(byte[] bytes) {
  2.  return new XidImpl("amqp".getBytes(), 1, bytes);
  3. }

代码示例来源：origin: apache/activemq-artemis

  1. @Override
  2. public String toString() {
  3.  return "XidImpl (" + System.identityHashCode(this) +
  4.    " bq:" +
  5.    stringRep(branchQualifier) +
  6.    " formatID:" +
  7.    formatId +
  8.    " gtxid:" +
  9.    stringRep(globalTransactionId) +
  10.    " base64:" + toBase64String(this);
  11. }

代码示例来源：origin: apache/activemq-artemis

  1. @Override
  2. public String[] listHeuristicRolledBackTransactions() {
  3.  checkStarted();
  4.  clearIO();
  5.  try {
  6.    List<Xid> xids = resourceManager.getHeuristicRolledbackTransactions();
  7.    String[] s = new String[xids.size()];
  8.    int i = 0;
  9.    for (Xid xid : xids) {
  10.     s[i++] = XidImpl.toBase64String(xid);
  11.    }
  12.    return s;
  13.  } finally {
  14.    blockOnIO();
  15.  }
  16. }

代码示例来源：origin: apache/activemq-artemis

  1. private void calcHash() {
  2.  byte[] hashBytes = XidImpl.toByteArray(this);
  3.  hash = Arrays.hashCode(hashBytes);
  4.  hashCalculated = true;
  5. }

代码示例来源：origin: apache/activemq-artemis

  1. @Override
  2. public int hashCode() {
  3.  if (!hashCalculated) {
  4.    calcHash();
  5.  }
  6.  return hash;
  7. }

代码示例来源：origin: apache/activemq-artemis

  1. /**
  2. * Copy constructor
  3. *
  4. * @param other
  5. */
  6. public XidImpl(final Xid other) {
  7.  branchQualifier = copyBytes(other.getBranchQualifier());
  8.  formatId = other.getFormatId();
  9.  globalTransactionId = copyBytes(other.getGlobalTransactionId());
  10. }

代码示例来源：origin: org.apache.activemq/artemis-amqp-protocol

  1. protected XidImpl newXID(byte[] bytes) {
  2.  return new XidImpl("amqp".getBytes(), 1, bytes);
  3. }

代码示例来源：origin: apache/activemq-artemis

  1. @Override
  2. public String toString() {
  3.  return "XidImpl (" + System.identityHashCode(this) +
  4.    " bq:" +
  5.    stringRep(branchQualifier) +
  6.    " formatID:" +
  7.    formatId +
  8.    " gtxid:" +
  9.    stringRep(globalTransactionId) +
  10.    " base64:" + toBase64String(this);
  11. }

代码示例来源：origin: apache/activemq-artemis

  1. public JsonObject toJSON() throws Exception {
  2.  DateFormat dateFormat = DateFormat.getDateTimeInstance(DateFormat.SHORT, DateFormat.MEDIUM);
  3.  JsonObjectBuilder detailJson = JsonLoader.createObjectBuilder().add(KEY_CREATION_TIME, dateFormat.format(new Date(this.creationTime))).add(KEY_XID_AS_BASE64, XidImpl.toBase64String(this.xid)).add(KEY_XID_FORMAT_ID, this.xid.getFormatId()).add(KEY_XID_GLOBAL_TXID, new String(this.xid.getGlobalTransactionId())).add(KEY_XID_BRANCH_QUAL, new String(this.xid.getBranchQualifier()));

代码示例来源：origin: org.apache.activemq/artemis-jms-client-all

  1. private void calcHash() {
  2.  byte[] hashBytes = XidImpl.toByteArray(this);
  3.  hash = Arrays.hashCode(hashBytes);
  4.  hashCalculated = true;
  5. }

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

XidImpl

相关文章

    查看更多

    热门标签

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

    最新文章

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