[...] 
 
public class Server { 
public final static int JMX_DEFAULT_LEASE = 60; 
private static boolean debug = false; 
private final MBeanServer mbs; 
public Server() { 
mbs = MBeanServerFactory.createMBeanServer(); 
   } 
 
public static DirContext getRootContext() throws NamingException { 
final Hashtable env = new Hashtable(); 
 
final String factory = 
System.getProperty(Context.INITIAL_CONTEXT_FACTORY, 
"com.sun.jndi.ldap.LdapCtxFactory"); 
final String ldapServerUrl = 
System.getProperty(Context.PROVIDER_URL); 
final String ldapUser = 
System.getProperty(Context.SECURITY_PRINCIPAL, 
"cn=Directory Manager"); 
final String ldapPasswd = 
System.getProperty(Context.SECURITY_CREDENTIALS); 
debug(Context.PROVIDER_URL + "=" + ldapServerUrl); 
debug(Context.SECURITY_PRINCIPAL + "=" + ldapUser); 
if (debug) { 
System.out.print(Context.SECURITY_CREDENTIALS + "="); 
final int len = (ldapPasswd==null)?0:ldapPasswd.length(); 
for (int i=0;i<len;i++) System.out.print("*"); 
System.out.println(); 
      } 
env.put(Context.INITIAL_CONTEXT_FACTORY,factory); 
env.put(Context.SECURITY_PRINCIPAL, ldapUser); 
if (ldapServerUrl != null) 
env.put(Context.PROVIDER_URL, ldapServerUrl); 
if (ldapPasswd != null) 
env.put(Context.SECURITY_CREDENTIALS, ldapPasswd); 
InitialContext root = new InitialLdapContext(env,null); 
return (DirContext)(root.lookup("")); 
  } 
   
[...] 
 

[...] 
 
public static void register(DirContext root, 
JMXServiceURL jmxUrl, 
String name) 
throws NamingException, IOException { 
 
final String mydn = System.getProperty("dn","cn="+name); 
 
debug("dn:" + mydn ); 
 
Object o = null; 
try { 
o = root.lookup(mydn); 
} catch (NameNotFoundException n) { 
Attributes attrs = new BasicAttributes(); 
Attribute objclass = new BasicAttribute("objectClass"); 
objclass.add("top"); 
objclass.add("javaContainer"); 
objclass.add("jmxConnector"); 
attrs.put(objclass); 
attrs.put("jmxAgentName", name); 
o = root.createSubcontext(mydn,attrs); 
   } 
if (o == null) throw new NameNotFoundException(); 
final Attributes attrs = root.getAttributes(mydn); 
final Attribute oc = attrs.get("objectClass"); 
if (!oc.contains("jmxConnector")) { 
final String msg = "The supplied node [" + mydn +  
"] does not contain the jmxConnector objectclass"; 
throw new NamingException(msg); 
   } 
    
final Attributes newattrs = new BasicAttributes(); 
newattrs.put("jmxAgentName",name); 
newattrs.put("jmxServiceURL",jmxUrl.toString()); 
newattrs.put("jmxAgentHost",InetAddress.getLocalHost().getHostName()); 
newattrs.put("jmxProtocolType",jmxUrl.getProtocol()); 
newattrs.put("jmxExpirationDate", 
getExpirationDate(JMX_DEFAULT_LEASE)); 
root.modifyAttributes(mydn,DirContext.REPLACE_ATTRIBUTE,newattrs); 
} 
 
[...] 
 

 
[...] 
 
public JMXConnectorServer rmi(String url) 
throws IOException, JMException, 
NamingException, ClassNotFoundException { 
 
JMXServiceURL jurl = new JMXServiceURL(url); 
final HashMap env = new HashMap(); 
// Prepare the environment Map 
     
[...] 
 
JMXConnectorServer rmis = 
        JMXConnectorServerFactory.newJMXConnectorServer(jurl, env, mbs); 
 
final String agentName = System.getProperty("agent.name", 
"DefaultAgent"); 
start(rmis,env,agentName); 
return rmis; 
   } 
     
[...] 
 

 
[...] 
 
public void start(JMXConnectorServer server, Map env, String agentName) 
throws IOException, NamingException { 
server.start(); 
final DirContext root=getRootContext(); 
final JMXServiceURL address = server.getAddress(); 
register(root,address,agentName); 
    } 
     
[...] 
 

 
[...] 
 
public class Client { 
 
private static boolean debug = false; 
 
public static void listAttributes(DirContext root, String dn) 
throws NamingException { 
final Attributes attrs = root.getAttributes(dn); 
System.out.println("dn:" + dn); 
System.out.println("attributes:" + attrs); 
   } 
    
public static DirContext getRootContext() throws NamingException { 
final Hashtable env = new Hashtable(); 
// Prepare environment map 
      [...] 
       
InitialContext root = new InitialLdapContext(env,null); 
return (DirContext)(root.lookup("")); 
   } 
    
// Confirm URL has not expired  
  [...]  
 
public static List lookup(DirContext root, String protocolType, 
String name) 
throws IOException, NamingException { 
final ArrayList list = new ArrayList(); 
String queryProtocol = 
(protocolType==null)?"":"(jmxProtocolType="+protocolType+")"; 
String query = 
"(&" + "(objectClass=jmxConnector) " + 
"(jmxServiceURL=*) " + 
queryProtocol + 
"(jmxAgentName=" + ((name!=null)?name:"*") + "))"; 
 
SearchControls ctrls = new SearchControls(); 
ctrls.setSearchScope(SearchControls.SUBTREE_SCOPE); 
final NamingEnumeration results = root.search("", query, ctrls); 
while (results.hasMore()) {  
final SearchResult r = (SearchResult) results.nextElement(); 
debug("Found node:" + r.getName()); 
final Attributes attrs = r.getAttributes(); 
final Attribute attr = attrs.get("jmxServiceURL"); 
if (attr == null) continue; 
final Attribute exp = attrs.get("jmxExpirationDate"); 
if ((exp != null) && hasExpired((String)exp.get())) { 
System.out.print(r.getName() + ": "); 
System.out.println("URL expired since:" + exp.get()); 
continue; 
           }   
final String urlStr = (String)attr.get(); 
if (urlStr.length() == 0) continue; 
 
    
debug("Found URL:"+ urlStr); 
 
    
final JMXServiceURL url = new JMXServiceURL(urlStr); 
final JMXConnector conn = 
JMXConnectorFactory.newJMXConnector(url,null); 
list.add(conn); 
if (debug) listAttributes(root,r.getName()); 
      } 
 
return list; 
 
   }   
}