817818819820821822823824825826827
res.start(xid1, XAResource.TMNOFLAGS); prod.send(tm); res.end(xid1, XAResource.TMSUCCESS); res.prepare(xid1); }
839840841842843844845846847848849
res.start(xid2, XAResource.TMNOFLAGS); prod.send(tm); res.end(xid2, XAResource.TMSUCCESS); res.prepare(xid2); }
945946947948949950951952953954955
967968969970971972973974975976977
11331134113511361137113811391140114111421143
11551156115711581159116011611162116311641165
181182183184185186187188189190191
m = cons2.receive(1000); ProxyAssertSupport.assertNull(m); res.end(xid1, XAResource.TMSUCCESS); // prepare it log.trace("Preparing xid " + xid1); res.prepare(xid1);
413414415416417418419420421422423
m = cons2.receive(1000); ProxyAssertSupport.assertNull(m); res.end(xid1, XAResource.TMSUCCESS); // prepare it res.prepare(xid1);
663664665666667668669670671672673
927928929930931932933934935936937