KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > prevayler > demos > scalability > prevayler > PrevaylerTransactionSubject


1 package org.prevayler.demos.scalability.prevayler;
2
3 import java.io.File JavaDoc;
4 import java.io.IOException JavaDoc;
5
6 import org.prevayler.PrevaylerFactory;
7
8 public class PrevaylerTransactionSubject extends PrevaylerScalabilitySubject {
9
10     private final String JavaDoc _logDirectory;
11     
12     public PrevaylerTransactionSubject(String JavaDoc logDirectory) throws java.io.IOException JavaDoc, ClassNotFoundException JavaDoc {
13         _logDirectory = logDirectory;
14         if (new File JavaDoc(_logDirectory).exists()) PrevalenceTest.delete(_logDirectory);
15         initializePrevayler();
16     }
17
18     public Object JavaDoc createTestConnection() {
19         return new PrevaylerTransactionConnection(prevayler);
20     }
21     
22     public boolean isConsistent() throws Exception JavaDoc {
23         int expectedResult = prevayler.prevalentSystem().hashCode();
24         initializePrevayler(); //Will reload all transactions from the log files.
25
return prevayler.prevalentSystem().hashCode() == expectedResult;
26     }
27
28     private void initializePrevayler() throws IOException JavaDoc, ClassNotFoundException JavaDoc {
29         prevayler = PrevaylerFactory.createPrevayler(new TransactionSystem(), _logDirectory); //No snapshot is generated by the test.
30
}
31 }
32
Popular Tags