Package org.jboss.messaging.core.impl.tx

Examples of org.jboss.messaging.core.impl.tx.Transaction.rollback()

950
951
952
953
954
955
956
957
958
959
960
      }

      // no messages in the channel yet
      assertEquals(0, queue.browse(null).size());

      tx.rollback();

      // still no messages in the channel
      assertEquals(0, queue.browse(null).size());
   }
View Full Code Here
1436
1437
1438
1439
1440
1441
1442
1443
1444
1445
1446
      // no message at the receiver
      assertTrue(r.getMessages().isEmpty());


      tx.rollback();

      // no messages in the channel
      assertEquals(0, queue.browse(null).size());

      // no message at the receiver
View Full Code Here
1482
1483
1484
1485
1486
1487
1488
1489
1490
1491
1492
      assertEquals(0, queue.browse(null).size());

      // no message at the receiver
      assertTrue(r.getMessages().isEmpty());

      tx.rollback();

      // no messages in the channel
      assertEquals(0, queue.browse(null).size());

      // no message at the receiver
View Full Code Here
1527
1528
1529
1530
1531
1532
1533
1534
1535
1536
1537
      assertEquals(0, queue.browse(null).size());

      // no message at the receiver
      assertTrue(r.getMessages().isEmpty());

      tx.rollback();

      // no messages in the channel
      assertEquals(0, queue.browse(null).size());

      // no message at the receiver
View Full Code Here
1573
1574
1575
1576
1577
1578
1579
1580
1581
1582
1583
      assertEquals(0, queue.browse(null).size());

      // no message at the receiver
      assertTrue(r.getMessages().isEmpty());

      tx.rollback();

      // no messages in the channel
      assertEquals(0, queue.browse(null).size());

      // no message at the receiver
View Full Code Here
1619
1620
1621
1622
1623
1624
1625
1626
1627
1628
1629
      assertEquals(0, queue.browse(null).size());

      // no message at the receiver
      assertTrue(r.getMessages().isEmpty());

      tx.rollback();

      // no messages in the channel
      assertEquals(0, queue.browse(null).size());

      // no message at the receiver
View Full Code Here
1806
1807
1808
1809
1810
1811
1812
1813
1814
1815
1816
      r.acknowledge(ackm, tx);

      deliveringCount = queue.getDeliveringCount();
      assertEquals(1, deliveringCount);

      tx.rollback();

      deliveringCount = queue.getDeliveringCount();
      assertEquals(1, deliveringCount);

      // acknowledge non-transactionally
View Full Code Here
1944
1945
1946
1947
1948
1949
1950
1951
1952
1953
1954
         Message ackm = (Message)i.next();
         // transacted acknowledgment
         r.acknowledge(ackm, tx);
      }

      tx.rollback();

      // acknowledge non-transactionally
      for(Iterator i = r.getMessages().iterator(); i.hasNext();)
      {
         Message ackm = (Message)i.next();
View Full Code Here
1430
1431
1432
1433
1434
1435
1436
1437
1438
1439
1440
      assertEquals(2, msgs.size());
      assertTrue(msgs.contains(new Long(ref1.getMessage().getMessageID())));
      assertTrue(msgs.contains(new Long(ref2.getMessage().getMessageID())));

      //rollback transaction
      tx.rollback();

      refs = getReferenceIds(channel.getChannelID());
      assertNotNull(refs);
      assertEquals(2, refs.size());
      assertTrue(refs.contains(new Long(ref1.getMessage().getMessageID())));
View Full Code Here
4960
4961
4962
4963
4964
4965
4966
4967
4968
4969
4970
      assertEquals(0, queue.browse(null).size());

      // no message at the receiver
      assertTrue(r.getMessages().isEmpty());

      tx.rollback();

      // no messages in the channel
      assertEquals(0, queue.browse(null).size());

      // no message at the receiver
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.