1 22 package org.jboss.test.recover.test; 23 24 import junit.framework.Test; 25 26 import org.jboss.logging.Logger; 27 import org.jboss.test.recover.interfaces.DummyXAResource; 28 29 35 public class RecoveryFromCrashAfterTxCommittedTestCase 36 extends JBossCrashRecoveryTestCase 37 { 38 private Logger log = Logger.getLogger(this.getClass()); 39 40 public RecoveryFromCrashAfterTxCommittedTestCase(String name) 41 { 42 super(name); 43 } 44 45 public void test() throws Exception 46 { 47 log.info("*** starting " + getUnqualifiedClassName() + " ***"); 48 49 DummyXAResource xaRes1 = getXAResource("DummyRecoverableProxy1"); 50 DummyXAResource xaRes2 = getXAResource("DummyRecoverableProxy2"); 51 DummyXAResource xaRes3 = getXAResource("DummyRecoverableProxy3"); 52 53 int xa1Commits = xaRes1.getCommittedCount(); 54 int xa2Commits = xaRes2.getCommittedCount(); 55 int xa3Commits = xaRes3.getCommittedCount(); 56 57 log.info("Commits after recovery: " + xa1Commits + ", " 58 + xa2Commits + ", " + xa3Commits); 59 60 assertEquals(N + 1, xa1Commits); 61 assertEquals(N + 1, xa2Commits); 62 assertEquals(N + 1, xa3Commits); 63 } 64 65 public static Test suite() throws Exception 66 { 67 return suite(RecoveryFromCrashAfterTxCommittedTestCase.class); 68 } 69 70 } 71 | Popular Tags |