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 RecoveryFromCrashAfterTxCommittedWithFailedXARetryAtRecoveryTimeTestCase 36 extends JBossCrashRecoveryTestCase 37 { 38 private Logger log = Logger.getLogger(this.getClass()); 39 40 public 41 RecoveryFromCrashAfterTxCommittedWithFailedXARetryAtRecoveryTimeTestCase( 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, xa2Commits); 64 assertEquals(N + 1, xa3Commits); 65 66 xa1Commits = xaRes1.getCommittedCount(); 67 xa2Commits = xaRes2.getCommittedCount(); 68 xa3Commits = xaRes3.getCommittedCount(); 69 70 Thread.sleep(5000); 71 72 log.info("Commits after failed retry timeout: " + xa1Commits + ", " 73 + xa2Commits + ", " + xa3Commits); 74 75 assertEquals(N + 1, xa1Commits); 76 assertEquals(N, xa2Commits); 77 assertEquals(N + 1, xa3Commits); 78 79 xaRes2.clearCommitErrorCode(); 80 Thread.sleep(5000); 81 82 xa1Commits = xaRes1.getCommittedCount(); 83 xa2Commits = xaRes2.getCommittedCount(); 84 xa3Commits = xaRes3.getCommittedCount(); 85 86 log.info("Commits after another retry timeout: " + xa1Commits + ", " 87 + xa2Commits + ", " + xa3Commits); 88 89 assertEquals(N + 1, xa1Commits); 90 assertEquals(N + 1, xa2Commits); 91 assertEquals(N + 1, xa3Commits); 92 } 93 94 public static Test suite() throws Exception 95 { 96 return suite(RecoveryFromCrashAfterTxCommittedWithFailedXARetryAtRecoveryTimeTestCase.class); 97 } 98 99 100 } 101 | Popular Tags |