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 RecoveryFromCrashAfterOneResourceButNotAllHavePreparedTestCase 36 extends JBossCrashRecoveryTestCase 37 { 38 private Logger log = Logger.getLogger(this.getClass()); 39 40 public RecoveryFromCrashAfterOneResourceButNotAllHavePreparedTestCase( 41 String name) 42 { 43 super(name); 44 } 45 46 public void test() throws Exception 47 { 48 log.info("*** starting " + getUnqualifiedClassName() + " ***"); 49 50 DummyXAResource xaRes1 = getXAResource("DummyRecoverableProxy1"); 51 DummyXAResource xaRes2 = getXAResource("DummyRecoverableProxy2"); 52 DummyXAResource xaRes3 = getXAResource("DummyRecoverableProxy3"); 53 54 int xa1Commits = xaRes1.getCommittedCount(); 55 int xa2Commits = xaRes2.getCommittedCount(); 56 int xa3Commits = xaRes3.getCommittedCount(); 57 58 int xa1Prepares = xaRes1.getPreparedCount(); 59 int xa2Prepares = xaRes2.getPreparedCount(); 60 int xa3Prepares = xaRes3.getPreparedCount(); 61 62 int xa1Rollbacks = xaRes1.getRollbackCount(); 63 int xa2Rollbacks = xaRes2.getRollbackCount(); 64 int xa3Rollbacks = xaRes3.getRollbackCount(); 65 66 log.info("Commits after crash: " + xa1Commits + ", " 67 + xa2Commits + ", " + xa3Commits); 68 log.info("Prepares after crash: " + xa1Prepares + ", " 69 + xa2Prepares + ", " + xa3Prepares); 70 log.info("Rollbacks after crash: " + xa1Rollbacks + ", " 71 + xa2Rollbacks + ", " + xa3Rollbacks); 72 73 assertEquals(N, xa1Commits); 74 assertEquals(N, xa2Commits); 75 assertEquals(N, xa3Commits); 76 assertEquals(N + 1, xa1Prepares); 77 assertEquals(N, xa2Prepares); 78 assertEquals(N, xa3Prepares); 79 assertEquals(1, xa1Rollbacks); 80 assertEquals(0, xa2Rollbacks); 81 assertEquals(0, xa3Rollbacks); 82 } 83 84 public static Test suite() throws Exception 85 { 86 return suite(RecoveryFromCrashAfterOneResourceButNotAllHavePreparedTestCase.class); 87 } 88 89 } 90 | Popular Tags |