Package javax.transaction.xa

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

3035
3036
3037
3038
3039
3040
3041
3042
3043
3044
3045
         assertEquals(0, xids2.length);
  
         assertTrue(xids[0].equals(xid1) || xids[1].equals(xid1));
         assertTrue(xids[0].equals(xid2) || xids[1].equals(xid2));
  
         res.commit(xids[0], false);
  
         res.commit(xids[1], false);
     
         conn3 = cf.createConnection();
  
View Full Code Here
3037
3038
3039
3040
3041
3042
3043
3044
3045
3046
3047
         assertTrue(xids[0].equals(xid1) || xids[1].equals(xid1));
         assertTrue(xids[0].equals(xid2) || xids[1].equals(xid2));
  
         res.commit(xids[0], false);
  
         res.commit(xids[1], false);
     
         conn3 = cf.createConnection();
  
         Session sessRec = conn3.createSession(false, Session.AUTO_ACKNOWLEDGE);
         MessageConsumer cons = sessRec.createConsumer(queue1);
View Full Code Here
3179
3180
3181
3182
3183
3184
3185
3186
3187
3188
3189
         assertEquals(0, xids2.length);
  
         assertTrue(xids[0].equals(xid1) || xids[1].equals(xid1));
         assertTrue(xids[0].equals(xid2) || xids[1].equals(xid2));
  
         res.commit(xids[0], false);
  
         res.commit(xids[1], false);
  
         conn3 = cf.createConnection();
  
View Full Code Here
3181
3182
3183
3184
3185
3186
3187
3188
3189
3190
3191
         assertTrue(xids[0].equals(xid1) || xids[1].equals(xid1));
         assertTrue(xids[0].equals(xid2) || xids[1].equals(xid2));
  
         res.commit(xids[0], false);
  
         res.commit(xids[1], false);
  
         conn3 = cf.createConnection();
  
         Session sessRec = conn3.createSession(false, Session.AUTO_ACKNOWLEDGE);
  
View Full Code Here
237
238
239
240
241
242
243
244
245
246
247
         assertEquals(xid1, xids[0]);
        
         log.trace("Committing the tx");
        
         //Commit
         res3.commit(xids[0], false);
        
         log.trace("committed the tx");
        
         conn1.close();
        
View Full Code Here
735
736
737
738
739
740
741
742
743
744
745
         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
1226
1227
1228
1229
1230
1231
1232
1233
1234
1235
1236
        
         //prepare it
        
         res.prepare(xid1);
        
         res.commit(xid1, false);
        
         conn1.close();
        
         conn2.close();
                                   
View Full Code Here
1127
1128
1129
1130
1131
1132
1133
1134
1135
1136
1137
         assertEqualByteArrays(trailing.getGlobalTransactionId(), trailing2.getGlobalTransactionId());

         assertEqualByteArrays(trailing.getBranchQualifier(), trailing2.getBranchQualifier());

         res.commit(trailing, false);
      }
      finally
      {
         removeAllMessages(queue1.getQueueName(), true, 0);
       
View Full Code Here
103
104
105
106
107
108
109
110
111
112
113
      {
         HornetQJMSServerLogger.LOGGER.debug("Commit " + xaResource + " xid " + " onePhase=" + onePhase);
      }
      try
      {
         xaResource.commit(xid, onePhase);
      }
      catch (XAException e)
      {
         throw check(e);
      }
View Full Code Here
290
291
292
293
294
295
296
297
298
299
300
         assertNull(rm1);

         // prepare the tx
         res1.prepare(xid1);

         res1.commit(xid1, false);

         rm1 = (TextMessage)cons.receive(2000);
         assertNotNull(rm1);
         assertEquals(rm1.getText(), tm2.getText());
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.