1 package org.prevayler.demos.scalability.prevayler; 2 3 import org.prevayler.demos.scalability.*; 4 import org.prevayler.Prevayler; 5 6 class PrevaylerTransactionConnection implements TransactionConnection { 7 8 private final Prevayler prevayler; 9 10 PrevaylerTransactionConnection(Prevayler prevayler) { 11 this.prevayler = prevayler; 12 } 13 14 public void performTransaction(Record recordToInsert, Record recordToUpdate, long idToDelete) { 15 try { 16 17 prevayler.execute(new TestTransaction(recordToInsert, recordToUpdate, idToDelete)); 18 19 } catch (Exception ex) { 20 ex.printStackTrace(); 21 throw new RuntimeException ("Unexpected Exception: " + ex); 22 } 23 } 24 } 25 | Popular Tags |