Package org.jboss.messaging.core.tx

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

267
268
269
270
271
272
273
274
275
276
277
         msgs[i] = CoreMessageFactory.createCoreMessage(i, false, null);
         refs[i] = ms.reference(msgs[i]);
         queue.handle(null, refs[i], tx);        
         refs[i].releaseMemoryReference();
      }     
      tx.commit();
     
      //verify 20 refs in storage
     
      refIds = getReferenceIdsOrderedByPageOrd(queue.getChannelID());
      assertEquals(20, refIds.size());
View Full Code Here
318
319
320
321
322
323
324
325
326
327
328
         msgs[i] = CoreMessageFactory.createCoreMessage(i, false, null);
         refs[i] = ms.reference(msgs[i]);
         queue.handle(null, refs[i], tx);        
         refs[i].releaseMemoryReference();
      } 
      tx.commit();
     
      //verify 30 refs in storage
     
      refIds = getReferenceIdsOrderedByPageOrd(queue.getChannelID());
      assertEquals(30, refIds.size());
View Full Code Here
359
360
361
362
363
364
365
366
367
368
369
         msgs[i] = CoreMessageFactory.createCoreMessage(i, false, null);
         refs[i] = ms.reference(msgs[i]);
         queue.handle(null, refs[i], tx);     
         refs[i].releaseMemoryReference();
      } 
      tx.commit();
     
      //verify 40 refs in storage
     
      refIds = getReferenceIdsOrderedByPageOrd(queue.getChannelID());
      assertEquals(40, refIds.size());
View Full Code Here
397
398
399
400
401
402
403
404
405
406
407
      tx = tr.createTransaction();
      msgs[140] = CoreMessageFactory.createCoreMessage(140, false, null);
      refs[140] = ms.reference(msgs[140]);
      queue.handle(null, refs[140], tx);
      refs[140].releaseMemoryReference();
      tx.commit();
     
      //verify 40 refs in storage
     
      refIds = getReferenceIdsOrderedByPageOrd(queue.getChannelID());
      assertEquals(40, refIds.size());
View Full Code Here
673
674
675
676
677
678
679
680
681
682
683
         msgs[i] = CoreMessageFactory.createCoreMessage(i, false, null);
         refs[i] = ms.reference(msgs[i]);
         queue.handle(null, refs[i], tx);
         refs[i].releaseMemoryReference();
      }
      tx.commit();
     
      //verify 0 ref in storage
     
      refIds = getReferenceIdsOrderedByPageOrd(queue.getChannelID());
      assertEquals(0, refIds.size());
View Full Code Here
711
712
713
714
715
716
717
718
719
720
721
         msgs[i] = CoreMessageFactory.createCoreMessage(i, false, null);
         refs[i] = ms.reference(msgs[i]);
         queue.handle(null, refs[i], tx);
         refs[i].releaseMemoryReference();
      }
      tx.commit();
     
      //verify 0 ref in storage
     
      refIds = getReferenceIdsOrderedByPageOrd(queue.getChannelID());
      assertEquals(0, refIds.size());
View Full Code Here
748
749
750
751
752
753
754
755
756
757
758
         msgs[i] = CoreMessageFactory.createCoreMessage(i, false, null);
         refs[i] = ms.reference(msgs[i]);
         queue.handle(null, refs[i], tx);
         refs[i].releaseMemoryReference();
      }
      tx.commit();
     
      //verify 20 ref in storage
     
      refIds = getReferenceIdsOrderedByPageOrd(queue.getChannelID());
      assertEquals(20, refIds.size());
View Full Code Here
79
80
81
82
83
84
85
86
87
88
89
         msgs[i] = CoreMessageFactory.createCoreMessage(i, true, null);
         refs[i] = ms.reference(msgs[i]);
         queue.handle(null, refs[i], tx);
         refs[i].releaseMemoryReference();
      }
      tx.commit();
     
      //verify no unloaded refs in storage
           
      List refIds = getPagedReferenceIds(queue.getChannelID());
      assertTrue(refIds.isEmpty());
View Full Code Here
119
120
121
122
123
124
125
126
127
128
129
      tx = tr.createTransaction();
      msgs[99] = CoreMessageFactory.createCoreMessage(99, true, null);
      refs[99] = ms.reference(msgs[99]);
      queue.handle(null, refs[99], tx);
      refs[99].releaseMemoryReference();
      tx.commit();
     
      //verify no unloaded refs in storage
     
      refIds = getPagedReferenceIds(queue.getChannelID());
      assertTrue(refIds.isEmpty());
View Full Code Here
162
163
164
165
166
167
168
169
170
171
172
         msgs[i] = CoreMessageFactory.createCoreMessage(i, true, null);
         refs[i] = ms.reference(msgs[i]);
         queue.handle(null, refs[i], tx);        
         refs[i].releaseMemoryReference();
      }
      tx.commit();
     
      //verify no unloaded refs in storage
     
      refIds = getPagedReferenceIds(queue.getChannelID());
      assertTrue(refIds.isEmpty());
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.