List of recoverJournal() Examples

Examples of recoverJournal()

nexj.core.rpc.ra.tx.PersistentJournal.recoverJournal()
Gets a MemoryJournal handle for the given transaction id, loading the list of transactional operations for that id from the journal file. @param xid The id of the transaction whose operations should beloaded into the handle. @return A MemoryJournal handle containing the transactionaloperations for the given XID.

Examples of nexj.core.rpc.ra.tx.PersistentJournal.recoverJournal()

      assertEquals(makeXid(3), recoveredXids[1]);
      assertEquals(makeXid(7), recoveredXids[2]);
      
      
      //Test getting some operations
      MemoryJournal recovered = recoverJournal.recoverJournal(makeXid(1));
      List recoveredOps = recovered.getRecords();
      
      //A record that needs to be recovered. (XID1)
      assertEquals(2, recoveredOps.size());
      assertEquals(new JournalRecordTesting(makeXid(1), FileJournalRecordCopyInsert.OPCODE), recoveredOps.get(0));

View Full Code Here

Examples of nexj.core.rpc.ra.tx.PersistentJournal.recoverJournal()

      assertEquals(new JournalRecordTesting(makeXid(1), FileJournalRecordCopyInsert.OPCODE), recoveredOps.get(0));
      assertEquals(new JournalRecordTesting(makeXid(1), JournalRecordPrepared.OPCODE), recoveredOps.get(1));
      recovered.forget(makeXid(1));
      
      //Completed record (XID2) interleaved with record needing recovery (XID3)
      recovered = recoverJournal.recoverJournal(makeXid(3));
      recoveredOps = recovered.getRecords();
      assertEquals(2, recoveredOps.size());
      assertEquals(new JournalRecordTesting(makeXid(3), FileJournalRecordCopyUpdate.OPCODE), recoveredOps.get(0));
      assertEquals(new JournalRecordTesting(makeXid(3), JournalRecordPrepared.OPCODE), recoveredOps.get(1));
      recovered.forget(makeXid(3));

View Full Code Here

Examples of nexj.core.rpc.ra.tx.PersistentJournal.recoverJournal()

      assertEquals(tempFile1, perJournal.getActiveJournal());
      assertEquals(nHeaderLength, tempFile2.length());
      assertTrue(tempFile1.length() > nZeroObjectsLength);
      j2 = null;
      
      j1 = perJournal.recoverJournal(makeXid(5));
      assertNotNull(j1);
      
      List opsList = j1.getRecords();
      
      assertEquals(2, opsList.size());

View Full Code Here

Examples of nexj.core.rpc.ra.tx.PersistentJournal.recoverJournal()

      //Temp directory should be empty
      assertEquals(0, m_outgoingTempDirectory.listFiles().length);
      
      //Journal must mark transaction as completed.
      pJournal = PersistentJournal.makeJournal(m_outgoingJournal);
      journal = pJournal.recoverJournal(makeXid(7));
      
      List recordsList = journal.getRecords();
      GenericJournalRecord lastRecord = (GenericJournalRecord)recordsList.get(recordsList.size() - 1);
      
      assertEquals(JournalRecordCompleted.OPCODE, lastRecord.getOpCode());

View Full Code Here

TOP

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.