11841185118611871188118911901191119211931194
m = cons2.receive(1000); ProxyAssertSupport.assertNull(m); res.end(xid1, XAResource.TMSUCCESS); // prepare it res.prepare(xid1);
13201321132213231324132513261327132813291330
TextMessage tm1 = sess1.createTextMessage("tm1"); prod1.send(tm1); res1.end(xid1, XAResource.TMSUCCESS); log.trace("Sent message"); // prepare tx
14531454145514561457145814591460146114621463
16291630163116321633163416351636163716381639
ProxyAssertSupport.assertNotNull(rm1); ProxyAssertSupport.assertEquals(tm1.getText(), rm1.getText()); res1.end(xid1, XAResource.TMSUCCESS); // prepare the tx res1.prepare(xid1);
17631764176517661767176817691770177117721773
19841985198619871988198919901991199219931994
m = sub2.receive(1000); ProxyAssertSupport.assertNull(m); res.end(xid1, XAResource.TMSUCCESS); // prepare it res.prepare(xid1);
22402241224222432244224522462247224822492250
24552456245724582459246024612462246324642465
TextMessage tm4 = sess2.createTextMessage("tm4"); prod2.send(tm4); res2.end(xid2, XAResource.TMSUCCESS); log.trace("Sent messages"); // prepare both txs
26462647264826492650265126522653265426552656
TextMessage tm2 = sess2.createTextMessage("beta"); prod2.send(tm2); res2.end(xid2, XAResource.TMSUCCESS); // prepare both txs res1.prepare(xid1); res2.prepare(xid2);
27992800280128022803280428052806280728082809
TextMessage tm2 = sess2.createTextMessage("testing2"); prod2.send(tm2); res2.end(xid2, XAResource.TMSUCCESS); // prepare both txs res1.prepare(xid1); res2.prepare(xid2);