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();
}

}

6 comments

  1. Hi,

    There is a simple bug, but would be good to fix it, so when executing the sample run at first shot>

    the ‘lenght’ variable is duplicated, so no all JMS servers are printed:

    ….
    int length = (int) serverRT.length;
    ….
    length = (int) queueBean.length;

    the easiest is to rename one of them and rename the rest depending scope.

    cheers,

    German

  2. just in case, tried to get the list of queus, had lot of problems, finally sth worked, just in case someone may need it:


    JMXServiceURL serviceUrl =
    new JMXServiceURL(“service:jmx:iiop://192.168.100.1:7001/jndi/weblogic.management.mbeanservers.runtime”);

    System.out.println(“Connecting to: ” + serviceUrl);

    Hashtable env = new Hashtable();
    env.put(JMXConnectorFactory.PROTOCOL_PROVIDER_PACKAGES,”weblogic.management.remote”);
    env.put(javax.naming.Context.SECURITY_PRINCIPAL, “weblogic”);
    env.put(javax.naming.Context.SECURITY_CREDENTIALS, “passw0rd”);

    jmxCon = JMXConnectorFactory.newJMXConnector(serviceUrl, env);
    jmxCon.connect();
    MBeanServerConnection con = jmxCon.getMBeanServerConnection();

    ObjectName xname = new ObjectName(“*:Type=weblogic.j2ee.descriptor.wl.QueueBean,*”);
    Set axmbeans = con.queryNames(xname, null);
    for (ObjectName mbeanName : axmbeans)
    {
    System.out.println(mbeanName);
    }

    Important is to have in ObjectName, a asterisk which in this context means any other attributes, except the given one

  3. Got it working for cluster using the below code

    service = new ObjectName(
    “com.bea:Name=DomainRuntimeService,”
    + “Type=weblogic.management.mbeanservers.domainruntime.DomainRuntimeServiceMBean”);

    …………..

    public static ObjectName[] getServerRuntimes() throws Exception {
    ObjectName[] serverRuntime = (ObjectName[]) connection.getAttribute(
    service, “ServerRuntimes”);

    return serverRuntime;
    }

    ………….

    in the main code:

    ObjectName[] serverRuntime = getServerRuntimes();

    for (int i1 = 0; i1 < serverRuntime.length; i1++)
    {
    ObjectName jmsRuntime = (ObjectName) connection.getAttribute(
    serverRuntime[i1], "JMSRuntime");
    ObjectName[] jmsServers = (ObjectName[]) connection.getAttribute(
    jmsRuntime, "JMSServers");

    then follow the same code as in the main thread..

Leave a Reply