runtimequeuecreater.java

精通Jboss——Ejb和Web Services开发精解的随书源代码

/**
 * Created on 2003-9-13
 */
package com.liuyang.jboss.message.jms.queue;

import java.net.InetAddress;
import java.util.Hashtable;

import javax.management.ObjectName;
import javax.naming.Context;
import javax.naming.InitialContext;

import org.jboss.jmx.adaptor.rmi.RMIAdaptor;
/**
 * @author
 * <a href="mailto:[e-mail]">刘洋</a>
 */
public class RuntimeQueueCreater {

	public static void main(String[] args) throws Exception {
		String serverName = serverName = InetAddress.getLocalHost().getHostName();
		Hashtable env = new Hashtable();
		env.put(Context.INITIAL_CONTEXT_FACTORY,"org.jnp.interfaces.NamingContextFactory");
		env.put(Context.PROVIDER_URL,"localhost");
		InitialContext ic = new InitialContext(env);
		RMIAdaptor server = (RMIAdaptor) ic.lookup("jmx:" + serverName + ":rmi");
		ObjectName name = new ObjectName("jboss.mq:service=DestinationManager");
		String[] sig = {"java.lang.String","java.lang.String"};
		Object[] opArgs = {"queueruntime","queue/queueruntime"};
		Object result = server.invoke(name, "createQueue", opArgs, sig);
		System.out.println(result);		
	}
}