14281429143014311432143314341435143614371438
TextMessage tm1 = sess1.createTextMessage("tm1"); prod1.send(tm1); res1.end(xid1, XAResource.TMSUCCESS); log.trace("Sent message"); //prepare tx
15661567156815691570157115721573157415751576
17501751175217531754175517561757175817591760
assertNotNull(rm1); assertEquals(tm1.getText(), rm1.getText()); res1.end(xid1, XAResource.TMSUCCESS); //prepare the tx res1.prepare(xid1);
18911892189318941895189618971898189919001901
21142115211621172118211921202121212221232124
m = sub2.receive(1000); assertNull(m); res.end(xid1, XAResource.TMSUCCESS); //prepare it res.prepare(xid1);
23692370237123722373237423752376237723782379
25822583258425852586258725882589259025912592
TextMessage tm4 = sess2.createTextMessage("tm4"); prod2.send(tm4); res2.end(xid2, XAResource.TMSUCCESS); log.trace("Sent messages"); //prepare both txs
27772778277927802781278227832784278527862787
TextMessage tm2 = sess2.createTextMessage("beta"); prod2.send(tm2); res2.end(xid2, XAResource.TMSUCCESS); //prepare both txs res1.prepare(xid1);
29362937293829392940294129422943294429452946
TextMessage tm2 = sess2.createTextMessage("testing2"); prod2.send(tm2); res2.end(xid2, XAResource.TMSUCCESS); //prepare both txs res1.prepare(xid1);
30773078307930803081308230833084308530863087