1 17 18 package org.sape.carbon.services.jmx.server.mx4j.test; 19 20 import java.util.Hashtable ; 21 import java.util.Iterator ; 22 import java.util.Set ; 23 24 import javax.naming.InitialContext ; 25 26 import org.sape.carbon.core.component.Lookup; 27 28 import junit.extensions.ActiveTestSuite; 29 import junit.framework.Test; 30 import junit.framework.TestCase; 31 import junit.framework.TestSuite; 32 33 import mx4j.connector.RemoteMBeanServer; 34 import mx4j.connector.rmi.RMIConnector; 35 import mx4j.connector.rmi.jrmp.JRMPConnector; 36 37 48 public class JrmpRemotingTest extends TestCase { 49 50 public JrmpRemotingTest(String name) { 51 super(name); 52 } 53 54 65 66 67 public void testConnect() throws Exception { 68 Lookup.getInstance().fetchComponent("/manage/RemoteAdminServer"); 70 71 String jndiName = "jrmp"; 73 74 Hashtable props = new Hashtable (); 75 props.put( 76 InitialContext.INITIAL_CONTEXT_FACTORY, 77 "com.sun.jndi.rmi.registry.RegistryContextFactory"); 78 props.put( 79 InitialContext.PROVIDER_URL, 80 "rmi://localhost:1099"); 81 82 RMIConnector connector = new JRMPConnector(); connector.connect(jndiName,props); 84 86 String remoteHostName = connector.getRemoteHostName(); 87 88 89 RemoteMBeanServer server = connector.getRemoteMBeanServer(); 91 92 Set mbeans = server.queryMBeans(null,null); 93 Iterator iter = mbeans.iterator(); 94 while (iter.hasNext()) { 95 iter.next().toString(); 97 99 } 100 101 } 102 103 104 108 public static Test suite() { 109 TestSuite masterSuite = new TestSuite("JrmpRemotingTest"); 110 111 Test singleThreadedTests = getSingleThreadedTests(); 113 if(singleThreadedTests != null) { 114 masterSuite.addTest(singleThreadedTests); 115 } 116 117 Test multiThreadedTests = getMultiThreadedTests(); 119 if(multiThreadedTests != null) { 120 masterSuite.addTest(multiThreadedTests); 121 } 122 123 return masterSuite; 124 } 125 126 135 private static Test getSingleThreadedTests() { 136 TestSuite suite = new TestSuite(); 137 143 suite.addTest(new JrmpRemotingTest("testConnect")); 144 return suite; 145 } 146 147 156 private static Test getMultiThreadedTests() { 157 TestSuite suite = new ActiveTestSuite(); 158 164 return suite; 165 } 166 167 177 private static void addTest(TestSuite suite, String testName, int number) { 178 for(int count=0; count<number; count++) { 179 suite.addTest(new JrmpRemotingTest(testName)); 180 } 181 } 182 } 183 | Popular Tags |