111112113114115116117118119120121
IDManager idm = new IDManager("TRANSACTION_ID", 10, pm); idm.start(); TransactionRepository tr = new TransactionRepository(pm, new SimpleMessageStore(), idm); tr.start(); Transaction tx = tr.createTransaction(); ((SimpleDelivery)delivery).acknowledge(tx);
13131314131513161317131813191320132113221323
IDManager idm = new IDManager("TRANSACTION_ID", 10, pm); idm.start(); TransactionRepository txRep = new TransactionRepository(pm, ms, idm); txRep.start(); log.debug("transaction log started"); Message[] messages = createMessages(10);
14241425142614271428142914301431143214331434
IDManager idm = new IDManager("TRANSACTION_ID", 10, pm); idm.start(); TransactionRepository txRep = new TransactionRepository(pm, ms, idm); txRep.start(); Message[] messages = createMessages(10); Message m1 = messages[0]; Message m2 = messages[1];