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 RecoveryFromCrashAfterTxCommittedWithSuccessfulXARetryAtRecoveryTimeTestCase 36 extends JBossCrashRecoveryTestCase 37 { 38 private Logger log = Logger.getLogger(this.getClass()); 39 40 public 41 RecoveryFromCrashAfterTxCommittedWithSuccessfulXARetryAtRecoveryTimeTestCase( 42 String name) 43 { 44 super(name); 45 } 46 47 public void test() throws Exception 48 { 49 log.info("*** starting " + getUnqualifiedClassName() + " ***"); 50 51 DummyXAResource xaRes1 = getXAResource("DummyRecoverableProxy1"); 52 DummyXAResource xaRes2 = getXAResource("DummyRecoverableProxy2"); 53 DummyXAResource xaRes3 = getXAResource("DummyRecoverableProxy3"); 54 55 int xa1Commits = xaRes1.getCommittedCount(); 56 int xa2Commits = xaRes2.getCommittedCount(); 57 int xa3Commits = xaRes3.getCommittedCount(); 58 59 log.info("Commits after recovery: " + xa1Commits + ", " 60 + xa2Commits + ", " + xa3Commits); 61 62 assertEquals(N + 1, xa1Commits); 63 assertEquals(N + 1, xa2Commits); 64 assertEquals(N + 1, xa3Commits); 65 } 66 67 public static Test suite() throws Exception 68 { 69 return suite(RecoveryFromCrashAfterTxCommittedWithSuccessfulXARetryAtRecoveryTimeTestCase.class); 70 } 71 72 } 73 | Popular Tags |