Package javax.transaction.xa

Examples of javax.transaction.xa.XAResource.commit()

1567
1568
1569
1570
1571
1572
1573
1574
1575
1576
1577
        
         log.trace("still can't see message");
        
         //Commit the tx
        
         res3.commit(xids[0], false);
        
         log.trace("committed");
        
         //The message should now be available
        
View Full Code Here
1848
1849
1850
1851
1852
1853
1854
1855
1856
1857
1858
         assertEquals(xid1, xids[0]);
                 
         //Commit the tx
        
         res3.commit(xids[0], false);
        
         //The message should be acknowldged
        
         conn3.close();
        
View Full Code Here
2055
2056
2057
2058
2059
2060
2061
2062
2063
2064
2065
         assertEquals(xid1, xids[0]);
        
         log.trace("Committing the tx");
        
         //Commit
         res3.commit(xids[0], false);
        
         log.trace("committed the tx");
        
         conn2.close();
        
View Full Code Here
2328
2329
2330
2331
2332
2333
2334
2335
2336
2337
2338
         assertEquals(xid1, xids[0]);
        
         log.trace("Committing the tx");
        
         //Commit
         res3.commit(xids[0], false);
        
         log.trace("committed the tx");
                          
         conn1 = cf.createConnection();
        
View Full Code Here
2568
2569
2570
2571
2572
2573
2574
2575
2576
2577
2578
        
         log.trace("comitting");
  
         //Commit tx1
        
         res.commit(xid1, false);
        
         log.trace("comitted");
        
        
         //Should now be able to receive tm1 and tm2
View Full Code Here
2590
2591
2592
2593
2594
2595
2596
2597
2598
2599
2600
         TextMessage m3 = (TextMessage)cons.receive(1000);
         assertNull(m3);
        
         //Now commit tx2
        
         res.commit(xid2, false);
        
         //Should now be able to receive tm3 and tm4
        
         m3 = (TextMessage)cons.receive(MAX_TIMEOUT);
         assertNotNull(m3);
View Full Code Here
2733
2734
2735
2736
2737
2738
2739
2740
2741
2742
2743
         assertEquals(0, xids2.length);
  
         assertTrue(xids[0].equals(xid1) || xids[1].equals(xid1));
         assertTrue(xids[0].equals(xid2) || xids[1].equals(xid2));
  
         res.commit(xid1, false);
  
         res.commit(xid2, false);
  
  
         conn3 = cf.createConnection();
View Full Code Here
2735
2736
2737
2738
2739
2740
2741
2742
2743
2744
2745
         assertTrue(xids[0].equals(xid1) || xids[1].equals(xid1));
         assertTrue(xids[0].equals(xid2) || xids[1].equals(xid2));
  
         res.commit(xid1, false);
  
         res.commit(xid2, false);
  
  
         conn3 = cf.createConnection();
  
         Session sessRec = conn3.createSession(false, Session.AUTO_ACKNOWLEDGE);
View Full Code Here
2893
2894
2895
2896
2897
2898
2899
2900
2901
2902
2903
         assertEquals(0, xids2.length);
  
         assertTrue(xids[0].equals(xid1) || xids[1].equals(xid1));
         assertTrue(xids[0].equals(xid2) || xids[1].equals(xid2));
    
         res.commit(xid1, false);
  
         res.commit(xid2, false);
     
         conn3 = cf.createConnection();
  
View Full Code Here
2895
2896
2897
2898
2899
2900
2901
2902
2903
2904
2905
         assertTrue(xids[0].equals(xid1) || xids[1].equals(xid1));
         assertTrue(xids[0].equals(xid2) || xids[1].equals(xid2));
    
         res.commit(xid1, false);
  
         res.commit(xid2, false);
     
         conn3 = cf.createConnection();
  
         Session sessRec = conn3.createSession(false, Session.AUTO_ACKNOWLEDGE);
         MessageConsumer cons = sessRec.createConsumer(queue1);
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.