1 22 package org.jboss.test.recover.test; 23 24 import javax.management.Attribute ; 25 import javax.management.MBeanServerConnection ; 26 import javax.management.ObjectName ; 27 import javax.rmi.PortableRemoteObject ; 28 import javax.transaction.TransactionRolledbackException ; 29 30 import junit.framework.Test; 31 32 import org.jboss.logging.Logger; 33 import org.jboss.test.recover.interfaces.DummyXAResource; 34 import org.jboss.test.recover.interfaces.XAResourceEnlisterCaller; 35 import org.jboss.test.recover.interfaces.XAResourceEnlisterCallerHome; 36 37 43 public class CrashOfFirstRemoteResourceBeforeItPreparesIIOPTestCase 44 extends JBossCrashRecoveryIIOPTestCase 45 { 46 private Logger log = Logger.getLogger(this.getClass()); 47 48 public CrashOfFirstRemoteResourceBeforeItPreparesIIOPTestCase(String name) 49 throws Exception 50 { 51 super(name); 52 } 53 54 public void test() throws Exception 55 { 56 log.info("*** starting " + getUnqualifiedClassName() + " ***"); 57 58 DummyXAResource xaRes1 = getXAResource("DummyRecoverableProxy1"); 59 DummyXAResource xaRes2 = getXAResource("DummyRecoverableProxy2"); 60 DummyXAResource xaRes3 = getXAResource("DummyRecoverableProxy3"); 61 62 xaRes1.clear(); 63 xaRes2.clear(); 64 xaRes3.clear(); 65 66 Object obj; 67 XAResourceEnlisterCallerHome home; 68 69 obj = getInitialContext().lookup( 70 "dtmrectest/XAResourceEnlisterCallerEJB"); 71 home = (XAResourceEnlisterCallerHome) 72 PortableRemoteObject.narrow(obj, XAResourceEnlisterCallerHome.class); 73 XAResourceEnlisterCaller xaResEnlisterCaller = home.create(); 74 75 for (int i = 0; i < N; i++) 76 xaResEnlisterCaller.callXAResourceEnlistersOverIIOP(); 77 78 int xa1CommitsBefore = xaRes1.getCommittedCount(); 79 int xa2CommitsBefore = xaRes2.getCommittedCount(); 80 int xa3CommitsBefore = xaRes3.getCommittedCount(); 81 82 log.info("Commits before crash of remote resource: " + xa1CommitsBefore + 83 ", " + xa2CommitsBefore + ", " + xa3CommitsBefore); 84 85 ObjectName logger = new ObjectName ("jboss:service=RecoveryLogger"); 86 MBeanServerConnection firstResource = getResource1Server(); 87 try 88 { 89 firstResource.setAttribute(logger, new Attribute ("CrashOnFailure", 94 Boolean.TRUE)); 95 firstResource.setAttribute(logger, new Attribute ("FailBeforePreparing", 96 Boolean.TRUE)); 97 firstResource.setAttribute(logger, new Attribute ("FailBefore", 98 new Integer (0))); 99 xaResEnlisterCaller.callXAResourceEnlistersOverIIOP(); 100 fail("TransactionRolledbackException expected."); 101 } 102 catch (TransactionRolledbackException e) 103 { 104 log.info("Expected exception: ", e); 105 } 106 catch (Throwable e) 107 { 108 log.info("Unexpected throwable:", e); 109 fail("Unexpected throwable: " + e); 110 } 111 112 int xa1CommitsAfter = xaRes1.getCommittedCount(); 113 int xa2CommitsAfter = xaRes2.getCommittedCount(); 114 int xa3CommitsAfter = xaRes3.getCommittedCount(); 115 116 int xa1Rollbacks = xaRes1.getRollbackCount(); 117 int xa2Rollbacks = xaRes2.getRollbackCount(); 118 int xa3Rollbacks = xaRes3.getRollbackCount(); 119 120 log.info("Commits after crash of remote resource: " + xa1CommitsAfter + 121 ", " + xa2CommitsAfter + ", " + xa3CommitsAfter); 122 log.info("Rollbacks after crash of remote resource: " + xa1CommitsAfter + 123 ", " + xa2CommitsAfter + ", " + xa3CommitsAfter); 124 125 assertEquals(3 * N, xa1CommitsBefore); 126 assertEquals(3 * N, xa2CommitsBefore); 127 assertEquals(2 * N, xa3CommitsBefore); 128 assertEquals(3 * N, xa1CommitsAfter); 129 assertEquals(3 * N, xa2CommitsAfter); 130 assertEquals(2 * N, xa3CommitsAfter); 131 assertEquals(2, xa1Rollbacks); 137 assertEquals(2, xa2Rollbacks); 138 assertEquals(1, xa3Rollbacks); 139 } 140 141 public static Test suite() throws Exception 142 { 143 return suite(CrashOfFirstRemoteResourceBeforeItPreparesIIOPTestCase.class); 144 } 145 146 } 147 | Popular Tags |