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

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

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

XidImpl.<init>介绍

[英]Copy constructor
[中]复制构造函数

代码示例

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

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

代码示例来源：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. public static XidImpl toXID(XATransactionId xaXid) {
  2.    return new XidImpl(xaXid.getBranchQualifier(), xaXid.getFormatId(), xaXid.getGlobalTransactionId());
  3.   }
  4. }

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

  1. XADummyEndpoint(CountDownLatch latch) {
  2.   super(latch);
  3.   xid = new XidImpl("xa1".getBytes(), 1, UUIDGenerator.getInstance().generateStringUUID().getBytes());
  4. }

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

  1. protected XidImpl newXID() {
  2.  return new XidImpl("xa1".getBytes(), 1, UUIDGenerator.getInstance().generateStringUUID().getBytes());
  3. }

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

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

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

  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: apache/activemq-artemis

  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: apache/activemq-artemis

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

  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: apache/activemq-artemis

  1. /**
  2. * In case a timeout happens the server's object may still have the previous XID.
  3. * for that reason a new start call is supposed to clean it up with a log.warn
  4. * but it should still succeed
  5. *
  6. * @throws Exception
  7. */
  8. @Test
  9. public void testChangeXID() throws Exception {
  10.  Xid xid = new XidImpl("xa1".getBytes(), 1, UUIDGenerator.getInstance().generateStringUUID().getBytes());
  11.  Xid xid2 = new XidImpl("xa1".getBytes(), 1, UUIDGenerator.getInstance().generateStringUUID().getBytes());
  12.  clientSession.start(xid, XAResource.TMNOFLAGS);
  13.  clientSession.start(xid2, XAResource.TMNOFLAGS);
  14. }

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

  1. public static Xid randomXid() {
  2.    return new XidImpl(randomBytes(), randomInt(), randomBytes());
  3.   }
  4. }

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

  1. @Test(timeout = 120000)
  2. public void testXAMessagesNotSentSoNoRollbackOnCommit() throws Exception {
  3.  createSessionFactory();
  4.  ClientSession session = createSession(sf, true, false, false);
  5.  Xid xid = new XidImpl("uhuhuhu".getBytes(), 126512, "auhsduashd".getBytes());
  6.  session.createQueue(FailoverTestBase.ADDRESS, RoutingType.MULTICAST, FailoverTestBase.ADDRESS, null, true);
  7.  ClientProducer producer = session.createProducer(FailoverTestBase.ADDRESS);
  8.  session.start(xid, XAResource.TMNOFLAGS);
  9.  sendMessagesSomeDurable(session, producer);
  10.  session.end(xid, XAResource.TMSUCCESS);
  11.  session.prepare(xid);
  12.  session.commit(xid, false);
  13.  crash(session);
  14.  ClientConsumer consumer = session.createConsumer(FailoverTestBase.ADDRESS);
  15.  session.start();
  16.  Xid xid2 = new XidImpl("tfytftyf".getBytes(), 54654, "iohiuohiuhgiu".getBytes());
  17.  session.start(xid2, XAResource.TMNOFLAGS);
  18.  receiveDurableMessages(consumer);
  19.  session.end(xid2, XAResource.TMSUCCESS);
  20.  session.prepare(xid2);
  21.  session.commit(xid2, false);
  22. }

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

  1. @Test(timeout = 120000)
  2. public void testXAMessagesConsumedSoRollbackOnEnd() throws Exception {
  3.  createSessionFactory();
  4.  ClientSession session1 = createSessionAndQueue();
  5.  ClientProducer producer = session1.createProducer(FailoverTestBase.ADDRESS);
  6.  sendMessagesSomeDurable(session1, producer);
  7.  session1.commit();
  8.  ClientSession session2 = createSession(sf, true, false, false);
  9.  ClientConsumer consumer = session2.createConsumer(FailoverTestBase.ADDRESS);
  10.  session2.start();
  11.  Xid xid = new XidImpl("uhuhuhu".getBytes(), 126512, "auhsduashd".getBytes());
  12.  session2.start(xid, XAResource.TMNOFLAGS);
  13.  receiveMessages(consumer);
  14.  crash(session2);
  15.  try {
  16.    session2.end(xid, XAResource.TMSUCCESS);
  17.    Assert.fail("Should throw exception");
  18.  } catch (XAException e) {
  19.    Assert.assertEquals(XAException.XAER_RMFAIL, e.errorCode);
  20.  }
  21. }

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

  1. @Test(timeout = 120000)
  2. public void testXAMessagesConsumedSoRollbackOnPrepare() throws Exception {
  3.  createSessionFactory();
  4.  ClientSession session1 = createSessionAndQueue();
  5.  ClientProducer producer = session1.createProducer(FailoverTestBase.ADDRESS);
  6.  sendMessagesSomeDurable(session1, producer);
  7.  session1.commit();
  8.  ClientSession session2 = createSession(sf, true, false, false);
  9.  ClientConsumer consumer = session2.createConsumer(FailoverTestBase.ADDRESS);
  10.  session2.start();
  11.  Xid xid = new XidImpl("uhuhuhu".getBytes(), 126512, "auhsduashd".getBytes());
  12.  session2.start(xid, XAResource.TMNOFLAGS);
  13.  receiveMessages(consumer);
  14.  session2.end(xid, XAResource.TMSUCCESS);
  15.  crash(session2);
  16.  try {
  17.    session2.prepare(xid);
  18.    Assert.fail("Should throw exception");
  19.  } catch (XAException e) {
  20.    Assert.assertEquals(XAException.XAER_RMFAIL, e.errorCode);
  21.  }
  22. }

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

  1. @Test
  2. public void testXAResourceRolledBackSuspendedNotRemoved() throws Exception {
  3.  Queue queue = null;
  4.  Xid xid = newXID();
  5.  try (XAConnection xaconnection = xaFactory.createXAConnection()) {
  6.    XASession session = xaconnection.createXASession();
  7.    queue = session.createQueue(queueName);
  8.    session.getXAResource().start(xid, XAResource.TMNOFLAGS);
  9.    session.getXAResource().end(xid, XAResource.TMSUSPEND);
  10.    XidImpl xid1 = new XidImpl(xid);
  11.    Transaction transaction = server.getResourceManager().getTransaction(xid1);
  12.    //directly suspend the tx
  13.    transaction.suspend();
  14.    session.getXAResource().rollback(xid);
  15.  } catch (XAException ex) {
  16.   //ignore
  17.  } finally {
  18.    XidImpl xid1 = new XidImpl(xid);
  19.    Transaction transaction = server.getResourceManager().getTransaction(xid1);
  20.    assertNotNull(transaction);
  21.  }
  22. }

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

  1. @Test
  2. public void testXAResourceCommittedRemoved() throws Exception {
  3.  Queue queue = null;
  4.  Xid xid = newXID();
  5.  try (XAConnection xaconnection = xaFactory.createXAConnection()) {
  6.    XASession session = xaconnection.createXASession();
  7.    queue = session.createQueue(queueName);
  8.    session.getXAResource().start(xid, XAResource.TMNOFLAGS);
  9.    MessageProducer producer = session.createProducer(queue);
  10.    producer.send(session.createTextMessage("xa message"));
  11.    session.getXAResource().end(xid, XAResource.TMSUCCESS);
  12.    session.getXAResource().commit(xid, true);
  13.  }
  14.  XidImpl xid1 = new XidImpl(xid);
  15.  Transaction transaction = server.getResourceManager().getTransaction(xid1);
  16.  assertNull(transaction);
  17. }

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

  1. @Test
  2. public void testXAResourceRolledBackRemoved() throws Exception {
  3.  Queue queue = null;
  4.  Xid xid = newXID();
  5.  try (XAConnection xaconnection = xaFactory.createXAConnection()) {
  6.    XASession session = xaconnection.createXASession();
  7.    queue = session.createQueue(queueName);
  8.    session.getXAResource().start(xid, XAResource.TMNOFLAGS);
  9.    MessageProducer producer = session.createProducer(queue);
  10.    producer.send(session.createTextMessage("xa message"));
  11.    session.getXAResource().end(xid, XAResource.TMSUCCESS);
  12.    session.getXAResource().rollback(xid);
  13.  }
  14.  XidImpl xid1 = new XidImpl(xid);
  15.  Transaction transaction = server.getResourceManager().getTransaction(xid1);
  16.  assertNull(transaction);
  17. }

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

XidImpl

相关文章

    查看更多

    热门标签

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

    最新文章

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