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

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

3971
3972
3973
3974
3975
3976
3977
3978
3979
3980
3981
      r.acknowledge(ackm, tx);

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

      tx.commit();

      assertTrue(queue.browse(null).isEmpty());
   }

View Full Code Here
4113
4114
4115
4116
4117
4118
4119
4120
4121
4122
4123
         r.acknowledge(ackm, tx);
      }

      assertEquals(NUMBER_OF_MESSAGES, queue.getDeliveringCount());

      tx.commit();

      assertTrue(queue.browse(null).isEmpty());
   }

View Full Code Here
4353
4354
4355
4356
4357
4358
4359
4360
4361
4362
4363
      r.acknowledge(ackm, tx);

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

      tx.commit();

      assertTrue(queue.browse(null).isEmpty());
   }

View Full Code Here
4498
4499
4500
4501
4502
4503
4504
4505
4506
4507
4508
         r.acknowledge(ackm, tx);
      }

      assertEquals(NUMBER_OF_MESSAGES, queue.getDeliveringCount());

      tx.commit();

      assertTrue(queue.browse(null).isEmpty());
   }

   ////////////
View Full Code Here
4601
4602
4603
4604
4605
4606
4607
4608
4609
4610
4611
      assertEquals(0, queue.browse(null).size());

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

      tx.commit();

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

      List acknowledging = r.getMessages();
View Full Code Here
4654
4655
4656
4657
4658
4659
4660
4661
4662
4663
4664
      assertEquals(0, queue.browse(null).size());

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

      tx.commit();

      assertEquals(NUMBER_OF_MESSAGES, queue.getDeliveringCount());
      assertEqualSets(refs, r.getMessages());

      for(Iterator i = r.getMessages().iterator(); i.hasNext();)
View Full Code Here
4706
4707
4708
4709
4710
4711
4712
4713
4714
4715
4716
      assertEquals(0, queue.browse(null).size());

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

      tx.commit();

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

      List acknowledging = r.getMessages();
View Full Code Here
4758
4759
4760
4761
4762
4763
4764
4765
4766
4767
4768
      assertEquals(0, queue.browse(null).size());

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

      tx.commit();


      assertEquals(NUMBER_OF_MESSAGES, queue.getDeliveringCount());
      assertEqualSets(refs, r.getMessages());
View Full Code Here
4812
4813
4814
4815
4816
4817
4818
4819
4820
4821
4822
      assertEquals(0, queue.browse(null).size());

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

      tx.commit();

      assertEquals(NUMBER_OF_MESSAGES, queue.getDeliveringCount());
      assertEqualSets(refs, r.getMessages());

      for(Iterator i = r.getMessages().iterator(); i.hasNext();)
View Full Code Here
1702
1703
1704
1705
1706
1707
1708
1709
1710
1711
1712
            log.warn("No " + (dlq ? "DLQ" : "expiry queue") + " has been specified so the message will be removed");

            del.acknowledge(tx);
         }

         tx.commit();
      }
      catch (Throwable t)
      {
         tx.rollback();
         throw t;
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.