JMS Resources using JMX

import java.io.IOException;
import java.net.MalformedURLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Hashtable;
import java.util.Iterator;

import javax.management.MBeanServerConnection;
import javax.management.MalformedObjectNameException;
import javax.management.ObjectName;
import javax.management.remote.JMXConnector;
import javax.management.remote.JMXConnectorFactory;
import javax.management.remote.JMXServiceURL;
import javax.naming.Context;
import javax.naming.InitialContext;

import weblogic.j2ee.descriptor.wl.JMSBean;
import weblogic.j2ee.descriptor.wl.JMSConnectionFactoryBean;
import weblogic.j2ee.descriptor.wl.QueueBean;
import weblogic.jms.extensions.JMSModuleHelper;
import weblogic.management.configuration.JMSSystemResourceMBean;

public class JMSResource {

private static MBeanServerConnection connection;
private static JMXConnector connector;
private static ObjectName service;

static {

try {

System.out.println(“…”);
service = new ObjectName(
“com.bea:Name=RuntimeService,” +
“Type=weblogic.management.mbeanservers.runtime.RuntimeServiceMBean”);
} catch (MalformedObjectNameException e) {
throw new AssertionError(e.getMessage());
}
}

public static void initConnection(String hostname, String portString,
String username, String password) throws IOException,
MalformedURLException {
String protocol = “t3”;
Integer portInteger = Integer.valueOf(portString);
int port = portInteger.intValue();
String jndiroot = “/jndi/”;
String mserver = “weblogic.management.mbeanservers.runtime”;
JMXServiceURL serviceURL = new JMXServiceURL(protocol, hostname, port,
jndiroot + mserver);
Hashtable h = new Hashtable();
h.put(Context.SECURITY_PRINCIPAL, username);
h.put(Context.SECURITY_CREDENTIALS, password);
h.put(JMXConnectorFactory.PROTOCOL_PROVIDER_PACKAGES,
“weblogic.management.remote”);
connector = JMXConnectorFactory.connect(serviceURL, h);
connection = connector.getMBeanServerConnection();
}

public static ObjectName[] getJMSServers() throws Exception {
ObjectName serverRuntime = (ObjectName) connection.getAttribute(
service, “ServerRuntime”);
ObjectName jmsRuntime = (ObjectName) connection.getAttribute(
serverRuntime, “JMSRuntime”);
ObjectName[] jmsServers = (ObjectName[]) connection.getAttribute(
jmsRuntime, “JMSServers”);
return jmsServers;
}

public static void testMethod() {

try {

Hashtable env = new Hashtable();
env.put(Context.INITIAL_CONTEXT_FACTORY, “weblogic.jndi.WLInitialContextFactory”);
env.put(Context.PROVIDER_URL, “t3://localhost:7001”);
env.put(Context.SECURITY_PRINCIPAL, “weblogic”);
env.put(Context.SECURITY_CREDENTIALS, “weblogic”);
Context ctx = new InitialContext(env);

ObjectName[] serverRT = getJMSServers();
int length = (int) serverRT.length;
System.out.println(“length:::” + length);

for (int i = 0; i < length; i++) {

System.out.println(“i:::” + i);

ObjectName[] queues = (ObjectName[]) connection.getAttribute(
serverRT[i], “Destinations”);

String jmsServerName = (String) connection.getAttribute(
serverRT[i], “Name”);
System.out.println(“JMS Server name:” + jmsServerName);

int queueCount = (int) queues.length;

for (int k = 0; k < queueCount; k++) {

String queueNameWithModule = (String) connection
.getAttribute(queues[k], “Name”);

Long messagesCurrentCount = (Long) connection.getAttribute(
queues[k], “MessagesCurrentCount”);
System.out.println(“messagesCurrentCount”
+ messagesCurrentCount);

String moduleName = queueNameWithModule.substring(0,
queueNameWithModule.indexOf(“!”));
System.out.println(“JMS module Name:” + moduleName);
String resourceName = moduleName;
String queueName = queueNameWithModule
.substring(queueNameWithModule.indexOf(“!”) + 1);
System.out.println(“queueName” + queueName);

JMSSystemResourceMBean jmsSR = JMSModuleHelper
.findJMSSystemResource(ctx, resourceName);
JMSBean jmsBean = jmsSR.getJMSResource();
JMSConnectionFactoryBean[] connectionFactoryBean = jmsBean
.getConnectionFactories();

int length1 = (int) connectionFactoryBean.length;

for (int j = 0; j < length1; j++) {

JMSConnectionFactoryBean jmsFactory = connectionFactoryBean[j];
System.out.println(“jmsFactory.getJNDIName()”
+ jmsFactory.getJNDIName());

}
QueueBean[] queueBean = jmsBean.getQueues();
length = (int) queueBean.length;

for (int m = 0; m < length; m++) {

QueueBean queue = queueBean[m];

if (queueName != null
&& queueName.equals(queue.getName())) {
System.out.println(“queue.getJNDIName()”
+ queue.getJNDIName());
}
}

}
break;
}
} catch (Exception e) {
e.printStackTrace();
}

}

public static void main(String[] args) throws Exception {

String hostname = “localhost”;
String portString = “7001”;
String username = “weblogic”;
String password = “weblogic”;
System.out.println(“initializing conenction….”);
initConnection(hostname, portString, username, password);
JMSResource.testMethod();
connector.close();
}

}