1 22 package org.jboss.test.aop.nonjunit; 23 24 import javax.naming.InitialContext ; 25 26 import org.jboss.test.JBossTestCase; 27 import junit.framework.Test; 28 import java.net.InetAddress ; 29 import javax.management.ObjectName ; 30 import org.jboss.jmx.adaptor.rmi.RMIAdaptor; 31 import java.util.Properties ; 32 import javax.naming.Context ; 33 import javax.naming.InitialContext ; 34 import java.util.List ; 35 41 42 public class ClusterCacheTester 43 { 44 static RMIAdaptor server1; 45 static RMIAdaptor server2; 46 public static void main(String args[] ) throws Exception 47 { 48 String serverName = InetAddress.getLocalHost().getHostName(); 49 String connectorName = "jmx:" + serverName + ":rmi"; 50 RMIAdaptor server1 = (RMIAdaptor)new InitialContext ().lookup(connectorName); 51 52 Properties p = new Properties (); 53 p.put(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory"); 54 p.put(Context.URL_PKG_PREFIXES, "jboss.naming:org.jnp.interfaces"); 55 p.put(Context.PROVIDER_URL, "localhost:11099"); 56 RMIAdaptor server2 = (RMIAdaptor)new InitialContext (p).lookup(connectorName); 57 ObjectName testerName = new ObjectName ("jboss.aop:name=CacheTester"); 58 59 int baseAge = 32; 60 61 62 for (int j = 0; j < 5; j++) 63 { 64 { 65 Object [] params = {}; 67 String [] sig = {}; 68 System.out.println("vmid server1: " + server1.invoke(testerName, "getVMID", params, sig)); 69 System.out.println("vmid server2: " + server2.invoke(testerName, "getVMID", params, sig)); 70 71 } 72 { 73 Object [] params = {"Bill"}; 74 String [] sig = {"java.lang.String"}; 75 Integer age1 = (Integer )server1.invoke(testerName, "getAge", params, sig); 76 System.out.println("server1 age: " + age1); 77 78 Integer age2 = (Integer )server2.invoke(testerName, "getAge", params, sig); 79 System.out.println("server2 age: " + age2); 80 } 81 { 82 System.out.println("set age to " + ++baseAge + " on server1"); 83 Object [] params = {"Bill", new Integer (baseAge)}; 84 String [] sig = {"java.lang.String", "int"}; 85 server1.invoke(testerName, "setAge", params, sig); 86 } 87 { 88 System.out.println("check age"); 89 Object [] params = {"Bill"}; 90 String [] sig = {"java.lang.String"}; 91 Integer age1 = (Integer )server1.invoke(testerName, "getAge", params, sig); 92 System.out.println("server1 age: " + age1); 93 94 Integer age2 = (Integer )server2.invoke(testerName, "getAge", params, sig); 95 System.out.println("server2 age: " + age2); 96 } 97 { 98 Object [] params = {"Bill"}; 99 String [] sig = {"java.lang.String"}; 100 List hobbies = (List )server1.invoke(testerName, "getHobbies", params, sig); 101 System.out.println("server1 hobbies: "); 102 for (int i = 0; i < hobbies.size(); i++) 103 { 104 System.out.println(" " + hobbies.get(i)); 105 } 106 107 hobbies = (List )server2.invoke(testerName, "getHobbies", params, sig); 108 System.out.println("server2 hobbies: "); 109 for (int i = 0; i < hobbies.size(); i++) 110 { 111 System.out.println(" " + hobbies.get(i)); 112 } 113 } 114 { 115 System.out.println("addHobby fishing"); 116 Object [] params = {"Bill", "fishing"}; 117 String [] sig = {"java.lang.String", "java.lang.String"}; 118 server1.invoke(testerName, "addHobby", params, sig); 119 } 120 { 121 Object [] params = {"Bill"}; 122 String [] sig = {"java.lang.String"}; 123 List hobbies = (List )server1.invoke(testerName, "getHobbies", params, sig); 124 System.out.println("server1 hobbies: "); 125 for (int i = 0; i < hobbies.size(); i++) 126 { 127 System.out.println(" " + hobbies.get(i)); 128 } 129 130 hobbies = (List )server2.invoke(testerName, "getHobbies", params, sig); 131 System.out.println("server2 hobbies: "); 132 for (int i = 0; i < hobbies.size(); i++) 133 { 134 System.out.println(" " + hobbies.get(i)); 135 } 136 } 137 { 138 Object [] params = {"Bill"}; 139 String [] sig = {"java.lang.String"}; 140 String city1= (String )server1.invoke(testerName, "getCity", params, sig); 141 System.out.println("server1 city: " + city1); 142 143 String city2 = (String )server2.invoke(testerName, "getCity", params, sig); 144 System.out.println("server2 city: " + city2); 145 } 146 { 147 System.out.println("set city to Atlanta"); 148 Object [] params = {"Bill", "Atlanta" + baseAge}; 149 String [] sig = {"java.lang.String", "java.lang.String"}; 150 server1.invoke(testerName, "setCity", params, sig); 151 } 152 { 153 Object [] params = {"Bill"}; 154 String [] sig = {"java.lang.String"}; 155 String city1= (String )server1.invoke(testerName, "getCity", params, sig); 156 System.out.println("server1 city: " + city1); 157 158 String city2 = (String )server2.invoke(testerName, "getCity", params, sig); 159 System.out.println("server2 city: " + city2); 160 } 161 } 162 } 163 } 164 | Popular Tags |