Package org.jboss.messaging.core.tx

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

337
338
339
340
341
342
343
344
345
346
347
         Message m = CoreMessageFactory.createCoreMessage(i, true, null);
         MessageReference ref = ms.reference(m);
         queue.handle(null, ref, tx);      
         ref.releaseMemoryReference();
      } 
      tx.prepare();
      tx.rollback();
     
     
      //Send 10 more refs
      tx = createXATx();
View Full Code Here
350
351
352
353
354
355
356
357
358
359
360
         msgs[i] = CoreMessageFactory.createCoreMessage(i, true, null);
         refs[i] = ms.reference(msgs[i]);
         queue.handle(null, refs[i], null);        
         refs[i].releaseMemoryReference();
      } 
      tx.prepare();
      tx.commit();
     
      //verify 30 unloaded refs in storage
     
      refIds = getPagedReferenceIds(queue.getChannelID());
View Full Code Here
396
397
398
399
400
401
402
403
404
405
406
         msgs[i] = CoreMessageFactory.createCoreMessage(i, true, null);
         refs[i] = ms.reference(msgs[i]);
         queue.handle(null, refs[i], null);     
         refs[i].releaseMemoryReference();
      } 
      tx.prepare();
      tx.commit();
     
      //verify 40 unloaded refs in storage
     
      refIds = getPagedReferenceIds(queue.getChannelID());
View Full Code Here
439
440
441
442
443
444
445
446
447
448
449
      tx = createXATx();
      msgs[140] = CoreMessageFactory.createCoreMessage(140, true, null);
      refs[140] = ms.reference(msgs[140]);
      queue.handle(null, refs[140], null);
      refs[140].releaseMemoryReference();
      tx.prepare();
      tx.commit();
     
      //verify 40 unloaded refs in storage
     
      refIds = getPagedReferenceIds(queue.getChannelID());
View Full Code Here
758
759
760
761
762
763
764
765
766
767
768
         msgs[i] = CoreMessageFactory.createCoreMessage(i, true, null);
         refs[i] = ms.reference(msgs[i]);
         queue.handle(null, refs[i], null);
         refs[i].releaseMemoryReference();
      }
      tx.prepare();
      tx.commit();
     
      refIds = getPagedReferenceIds(queue.getChannelID());
      assertEquals(0, refIds.size());
     
View Full Code Here
801
802
803
804
805
806
807
808
809
810
811
         msgs[i] = CoreMessageFactory.createCoreMessage(i, true, null);
         refs[i] = ms.reference(msgs[i]);
         queue.handle(null, refs[i], null);
         refs[i].releaseMemoryReference();
      }
      tx.prepare();
      tx.commit();
     
      refIds = getPagedReferenceIds(queue.getChannelID());
      assertEquals(0, refIds.size());
     
View Full Code Here
843
844
845
846
847
848
849
850
851
852
853
         msgs[i] = CoreMessageFactory.createCoreMessage(i, true, null);
         refs[i] = ms.reference(msgs[i]);
         queue.handle(null, refs[i], null);
         refs[i].releaseMemoryReference();
      }
      tx.prepare();
      tx.commit();
     
      //verify 20 unloaded ref in storage
     
      refIds = getPagedReferenceIds(queue.getChannelID());
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
         refs2[i] = ms.reference(msgs[i]);
        
         queue2.handle(null, refs2[i], tx);
         refs2[i].releaseMemoryReference();
      }
      tx.prepare();
      tx.commit();
       
      //Queue1
      List refIds = getReferenceIdsOrderedByPageOrd(queue1.getChannelID());
      assertEquals(0, refIds.size());
View Full Code Here
142
143
144
145
146
147
148
149
150
151
152
        
         queue2.handle(null, refs2[i], tx);
        
         refs2[i].releaseMemoryReference();
      }
      tx.prepare();
      tx.commit();
      
      //Queue1
      refIds = getReferenceIdsOrderedByPageOrd(queue1.getChannelID());
             
View Full Code Here
196
197
198
199
200
201
202
203
204
205
206
        
         queue2.handle(null, refs2[i], tx);
        
         refs2[i].releaseMemoryReference();
      }
      tx.prepare();
      tx.commit();
     
      //Queue1
      refIds = getReferenceIdsOrderedByPageOrd(queue1.getChannelID());
               
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.