Package javax.transaction.xa

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

2961
2962
2963
2964
2965
2966
2967
2968
2969
2970
2971
         conn1 = JMSTestCase.cf.createXAConnection();

         XAResource res = conn1.createXASession().getXAResource();

         Xid[] xids = res.recover(XAResource.TMSTARTRSCAN);
         ProxyAssertSupport.assertEquals(2, xids.length);

         Xid[] xids2 = res.recover(XAResource.TMENDRSCAN);
         ProxyAssertSupport.assertEquals(0, xids2.length);
View Full Code Here
2964
2965
2966
2967
2968
2969
2970
2971
2972
2973
2974
         XAResource res = conn1.createXASession().getXAResource();

         Xid[] xids = res.recover(XAResource.TMSTARTRSCAN);
         ProxyAssertSupport.assertEquals(2, xids.length);

         Xid[] xids2 = res.recover(XAResource.TMENDRSCAN);
         ProxyAssertSupport.assertEquals(0, xids2.length);

         ProxyAssertSupport.assertTrue(xids[0].equals(xid1) || xids[1].equals(xid1));
         ProxyAssertSupport.assertTrue(xids[0].equals(xid2) || xids[1].equals(xid2));
View Full Code Here
3102
3103
3104
3105
3106
3107
3108
3109
3110
3111
3112
         conn1 = JMSTestCase.cf.createXAConnection();

         XAResource res = conn1.createXASession().getXAResource();

         Xid[] xids = res.recover(XAResource.TMSTARTRSCAN);
         ProxyAssertSupport.assertEquals(2, xids.length);

         Xid[] xids2 = res.recover(XAResource.TMENDRSCAN);
         ProxyAssertSupport.assertEquals(0, xids2.length);
View Full Code Here
3105
3106
3107
3108
3109
3110
3111
3112
3113
3114
3115
         XAResource res = conn1.createXASession().getXAResource();

         Xid[] xids = res.recover(XAResource.TMSTARTRSCAN);
         ProxyAssertSupport.assertEquals(2, xids.length);

         Xid[] xids2 = res.recover(XAResource.TMENDRSCAN);
         ProxyAssertSupport.assertEquals(0, xids2.length);

         ProxyAssertSupport.assertTrue(xids[0].equals(xid1) || xids[1].equals(xid1));
         ProxyAssertSupport.assertTrue(xids[0].equals(xid2) || xids[1].equals(xid2));
View Full Code Here
78
79
80
81
82
83
84
85
86
87
88
         HornetQJMSServerLogger.LOGGER.debug("looking for recover at " + xaResource + " configuration " + Arrays.toString(this.xaRecoveryConfigs));
      }

      try
      {
         Xid[] xids = xaResource.recover(flag);

         if (HornetQJMSServerLogger.LOGGER.isDebugEnabled() && xids != null && xids.length > 0)
         {
            HornetQJMSServerLogger.LOGGER.debug("Recovering these following IDs " + Arrays.toString(xids) + " at " + this);
         }
View Full Code Here
45
46
47
48
49
50
51
52
53
      waitForClusterToForm();
   }

   public void testRecoveryHandler() throws Exception {
      final XAResource xaResource = cache(0).getAdvancedCache().getXAResource();
      final Xid[] recover = xaResource.recover(XAResource.TMSTARTRSCAN | XAResource.TMENDRSCAN);
      assert recover != null && recover.length == 0;
   }
}
View Full Code Here
234
235
236
237
238
239
240
241
242
243
244
                { "(1", "PREPARED", "false", "SKU", "UserTransaction" },
                { "(2", "PREPARED", "false", "SKU", "UserTransaction" } };

        XATestUtil.checkXATransactionView(conn, expectedRows);

        Xid[] recoveredStart = xar.recover(XAResource.TMSTARTRSCAN);
        assertEquals(2, recoveredStart.length);
        Xid[] recovered = xar.recover(XAResource.TMNOFLAGS);
        assertEquals(0, recovered.length);
        Xid[] recoveredEnd = xar.recover(XAResource.TMENDRSCAN);
        assertEquals(0, recoveredEnd.length);
View Full Code Here
236
237
238
239
240
241
242
243
244
245
246
        XATestUtil.checkXATransactionView(conn, expectedRows);

        Xid[] recoveredStart = xar.recover(XAResource.TMSTARTRSCAN);
        assertEquals(2, recoveredStart.length);
        Xid[] recovered = xar.recover(XAResource.TMNOFLAGS);
        assertEquals(0, recovered.length);
        Xid[] recoveredEnd = xar.recover(XAResource.TMENDRSCAN);
        assertEquals(0, recoveredEnd.length);

        for (int i = 0; i < recoveredStart.length; i++) {
View Full Code Here
238
239
240
241
242
243
244
245
246
247
248
        Xid[] recoveredStart = xar.recover(XAResource.TMSTARTRSCAN);
        assertEquals(2, recoveredStart.length);
        Xid[] recovered = xar.recover(XAResource.TMNOFLAGS);
        assertEquals(0, recovered.length);
        Xid[] recoveredEnd = xar.recover(XAResource.TMENDRSCAN);
        assertEquals(0, recoveredEnd.length);

        for (int i = 0; i < recoveredStart.length; i++) {
            Xid xid = recoveredStart[i];
            if (xid.getFormatId() == 1) {
View Full Code Here
1390
1391
1392
1393
1394
1395
1396
1397
1398
1399
1400
        
         XASession sess3 = conn3.createXASession();
        
         XAResource res3 = sess3.getXAResource();
        
         Xid[] xids = res3.recover(XAResource.TMSTARTRSCAN);
         assertEquals(1, xids.length);
        
         Xid[] xids2 = res3.recover(XAResource.TMENDRSCAN);
         assertEquals(0, xids2.length);
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.