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