org.apache.activemq.artemis.core.transaction.impl.XidImpl.toBase64String()方法的使用及代码示例

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

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

XidImpl.toBase64String介绍

暂无

代码示例

代码示例来源：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: 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 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: org.apache.activemq/artemis-jms-client-all

  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: org.jboss.eap/wildfly-client-all

  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 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: org.apache.activemq/artemis-core-client

  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[] 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. @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: 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. 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: apache/activemq-artemis

  1. @Override
  2. public synchronized boolean commitPreparedTransaction(final String transactionAsBase64) throws Exception {
  3.  checkStarted();
  4.  clearIO();
  5.  try {
  6.    List<Xid> xids = resourceManager.getPreparedTransactions();
  7.    for (Xid xid : xids) {
  8.     if (XidImpl.toBase64String(xid).equals(transactionAsBase64)) {
  9.       Transaction transaction = resourceManager.removeTransaction(xid);
  10.       transaction.commit(false);
  11.       long recordID = server.getStorageManager().storeHeuristicCompletion(xid, true);
  12.       storageManager.waitOnOperations();
  13.       resourceManager.putHeuristicCompletion(recordID, xid, true);
  14.       return true;
  15.     }
  16.    }
  17.    return false;
  18.  } finally {
  19.    blockOnIO();
  20.  }
  21. }

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

  1. @Override
  2. public synchronized boolean rollbackPreparedTransaction(final String transactionAsBase64) throws Exception {
  3.  checkStarted();
  4.  clearIO();
  5.  try {
  6.    List<Xid> xids = resourceManager.getPreparedTransactions();
  7.    for (Xid xid : xids) {
  8.     if (XidImpl.toBase64String(xid).equals(transactionAsBase64)) {
  9.       Transaction transaction = resourceManager.removeTransaction(xid);
  10.       transaction.rollback();
  11.       long recordID = server.getStorageManager().storeHeuristicCompletion(xid, false);
  12.       server.getStorageManager().waitOnOperations();
  13.       resourceManager.putHeuristicCompletion(recordID, xid, false);
  14.       return true;
  15.     }
  16.    }
  17.    return false;
  18.  } finally {
  19.    blockOnIO();
  20.  }
  21. }

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

  1. @Test
  2. public void testForgetHeuristicallyRolledBackXID() throws Exception {
  3.  Xid xid = newXID();
  4.  clientSession.start(xid, XAResource.TMNOFLAGS);
  5.  clientSession.end(xid, XAResource.TMSUCCESS);
  6.  clientSession.prepare(xid);
  7.  String[] preparedTransactions = messagingService.getActiveMQServerControl().listPreparedTransactions();
  8.  Assert.assertEquals(1, preparedTransactions.length);
  9.  System.out.println(preparedTransactions[0]);
  10.  Assert.assertTrue(messagingService.getActiveMQServerControl().rollbackPreparedTransaction(XidImpl.toBase64String(xid)));
  11.  Assert.assertEquals(1, messagingService.getActiveMQServerControl().listHeuristicRolledBackTransactions().length);
  12.  clientSession.forget(xid);
  13.  Assert.assertEquals(0, messagingService.getActiveMQServerControl().listHeuristicRolledBackTransactions().length);
  14. }

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

  1. @Test
  2. public void testForgetHeuristicallyCommittedXID() throws Exception {
  3.  Xid xid = newXID();
  4.  clientSession.start(xid, XAResource.TMNOFLAGS);
  5.  clientSession.end(xid, XAResource.TMSUCCESS);
  6.  clientSession.prepare(xid);
  7.  String[] preparedTransactions = messagingService.getActiveMQServerControl().listPreparedTransactions();
  8.  Assert.assertEquals(1, preparedTransactions.length);
  9.  System.out.println(preparedTransactions[0]);
  10.  Assert.assertTrue(messagingService.getActiveMQServerControl().commitPreparedTransaction(XidImpl.toBase64String(xid)));
  11.  Assert.assertEquals(1, messagingService.getActiveMQServerControl().listHeuristicCommittedTransactions().length);
  12.  clientSession.forget(xid);
  13.  Assert.assertEquals(0, messagingService.getActiveMQServerControl().listHeuristicCommittedTransactions().length);
  14. }

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

  1. receiveLocator.close();
  2. boolean success = serverControl.commitPreparedTransaction(XidImpl.toBase64String(xid));
  3. success = serverControl.commitPreparedTransaction(XidImpl.toBase64String(xid));

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

  1. jmxServer.commitPreparedTransaction(XidImpl.toBase64String(xid));
  2. } else {
  3.   jmxServer.rollbackPreparedTransaction(XidImpl.toBase64String(xid));

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

  1. Assert.assertTrue(messagingService.getActiveMQServerControl().commitPreparedTransaction(XidImpl.toBase64String(xid)));
  2.   Assert.assertEquals(1, messagingService.getActiveMQServerControl().listHeuristicCommittedTransactions().length);
  3. } else {
  4.   Assert.assertTrue(messagingService.getActiveMQServerControl().rollbackPreparedTransaction(XidImpl.toBase64String(xid)));
  5.   Assert.assertEquals(1, messagingService.getActiveMQServerControl().listHeuristicRolledBackTransactions().length);

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

  1. jmxServer.commitPreparedTransaction(XidImpl.toBase64String(xid));
  2. } else {
  3.   jmxServer.rollbackPreparedTransaction(XidImpl.toBase64String(xid));

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

  1. jmxServer.commitPreparedTransaction(XidImpl.toBase64String(xid));
  2. } else {
  3.   jmxServer.rollbackPreparedTransaction(XidImpl.toBase64String(xid));

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

XidImpl

相关文章

    查看更多

    热门标签

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

    最新文章

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