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 29 import junit.framework.Test; 30 31 import org.jboss.logging.Logger; 32 import org.jboss.test.recover.interfaces.DummyXAResource; 33 import org.jboss.test.recover.interfaces.XAResourceEnlisterCaller; 34 import org.jboss.test.recover.interfaces.XAResourceEnlisterCallerHome; 35 36 42 public class CrashAfterDistributedTxCommittedIIOPTestCase 43 extends JBossCrashRecoveryIIOPTestCase 44 { 45 private Logger log = Logger.getLogger(this.getClass()); 46 private MBeanServerConnection server = delegate.getServer(); 47 48 public CrashAfterDistributedTxCommittedIIOPTestCase(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: " + xa1CommitsBefore + ", " 83 + xa2CommitsBefore + ", " + xa3CommitsBefore); 84 85 ObjectName logger = new ObjectName ("jboss:service=RecoveryLogger"); 86 try 87 { 88 server.setAttribute(logger, new Attribute ("CrashOnFailure", 89 Boolean.TRUE)); 90 server.setAttribute(logger, new Attribute ("FailAfterCommitting", 91 Boolean.TRUE)); 92 server.setAttribute(logger, new Attribute ("FailAfter", 93 new Integer (0))); 94 xaResEnlisterCaller.callXAResourceEnlistersOverIIOP(); 95 fail("Server crash expected."); 96 } 97 catch (Throwable e) 98 { 99 if (e instanceof java.rmi.MarshalException ) 100 { 101 log.info("Expected throwable:", e); 102 } 103 else 104 { 105 log.info("Unexpected throwable:", e); 106 fail("Unexpected throwable: " + e); 107 } 108 } 109 110 int xa1CommitsAfter = xaRes1.getCommittedCount(); 111 int xa2CommitsAfter = xaRes2.getCommittedCount(); 112 int xa3CommitsAfter = xaRes3.getCommittedCount(); 113 114 log.info("Commits after crash: " + xa1CommitsAfter + ", " 115 + xa2CommitsAfter + ", " + xa3CommitsAfter); 116 117 assertEquals(3 * N, xa1CommitsBefore); 118 assertEquals(3 * N, xa2CommitsBefore); 119 assertEquals(2 * N, xa3CommitsBefore); 120 assertEquals(3 * N, xa1CommitsAfter); 121 assertEquals(3 * N, xa2CommitsAfter); 122 assertEquals(2 * N, xa3CommitsAfter); 123 } 124 125 public static Test suite() throws Exception 126 { 127 return suite(CrashAfterDistributedTxCommittedIIOPTestCase.class); 128 } 129 130 } 131 | Popular Tags |