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

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

1342
1343
1344
1345
1346
1347
1348
1349
1350
1351
1352
      assertEquals(0, queue.browse(null).size());

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

      tx.commit();

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

      assertEqualSets(refs, r.getMessages());
View Full Code Here
1387
1388
1389
1390
1391
1392
1393
1394
1395
1396
1397
      assertEquals(0, queue.browse(null).size());

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

      tx.commit();

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

      assertEqualSets(refs, r.getMessages());
View Full Code Here
1759
1760
1761
1762
1763
1764
1765
1766
1767
1768
1769
      r.acknowledge(ackm, tx);

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

      tx.commit();

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

      deliveringCount = queue.getDeliveringCount();
      assertEquals(0, deliveringCount);
View Full Code Here
1900
1901
1902
1903
1904
1905
1906
1907
1908
1909
1910
         Message ackm = (Message)i.next();
         // transacted acknowledgment
         r.acknowledge(ackm, tx);
      }

      tx.commit();

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

View Full Code Here
2057
2058
2059
2060
2061
2062
2063
2064
2065
2066
2067
      r.acknowledge(rm, tx);

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

      tx.commit();

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

   //////////
View Full Code Here
2158
2159
2160
2161
2162
2163
2164
2165
2166
2167
2168
      {
         Message ackm = (Message)i.next();
         r.acknowledge(ackm, tx);
      }

      tx.commit();

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

   //////
View Full Code Here
1335
1336
1337
1338
1339
1340
1341
1342
1343
1344
1345
      assertEquals(2, msgs.size());
      assertTrue(msgs.contains(new Long(ref1.getMessage().getMessageID())));
      assertTrue(msgs.contains(new Long(ref2.getMessage().getMessageID())));

      //commit transaction
      tx.commit();

      assertEquals("numberOfRegisteredTransactions",0,txRep.getNumberOfRegisteredTransactions());

      //check we can see only the last 3 refs
      refs = getReferenceIds(channel.getChannelID());
View Full Code Here
238
239
240
241
242
243
244
245
246
247
248
         if (tx)
         {
            if (xa)
            {
               theTx.prepare();
               theTx.commit();
            }
            else
            {
               theTx.commit();
            }
View Full Code Here
242
243
244
245
246
247
248
249
250
251
252
               theTx.prepare();
               theTx.commit();
            }
            else
            {
               theTx.commit();
            }
         }
      }
   }
View Full Code Here
485
486
487
488
489
490
491
492
493
494
495
         {
            if (trace) { log.trace(this + " received ONE_PHASE_COMMIT request"); }

            Transaction tx = tr.createTransaction();
            processTransaction(request.getState(), tx, checkForDuplicates);
            tx.commit();
         }
         else if (request.getRequestType() == TransactionRequest.TWO_PHASE_PREPARE_REQUEST)
         {
            if (trace) { log.trace(this + " received TWO_PHASE_COMMIT prepare request"); }
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.