2 Replies Latest reply on Sep 10, 2012 6:23 PM by jboss debugg

    Java API to get JBoss message queue information

    jboss debugg Newbie

      I have a message queue(JMS) in JBoss 5.1 Environment. I would like to read  how many messages being processed or struck (dead queue) by the queue programatically(Java API). Appreciate if some can point me to any documentation.

       

      thanks

      -Jd

        • 1. Re: Java API to get JBoss message queue information
          Justin Bertram Master

          The simplest way would be to query the MBean for the particular destination you care about.  You can get an administrative view of the relevant MBean by using the JMX Console.  Once you identify the properties you want you simply get those with your remote MBean client.

          • 2. Re: Java API to get JBoss message queue information
            jboss debugg Newbie

            thanks Justin

             

            https://community.jboss.org/wiki/HowDoIGetRemoteAccessToMyMBean

             

            code from above link

            Using the RMIAdaptor (weakly typed interface)

            The RMIAdaptor provides a remote view of the MBeanServer Note: Use the MBeanServerConnection interface rather than RMIAdaptor on the most recent versions of JBoss.  RMIAdaptor should not be used in version 6.0 (M3) or greater (you must use MBeanServerConnection).

            //import org.jboss.jmx.adapter.rmi.RMIAdaptor; import javax.management.MBeanServerConnection;   public void doSomething() throws Exception {    InitialContext ctx = new InitialContext(); // From jndi.properties    //RMIAdaptor server = (RMIAdaptor) ctx.lookup("jmx/invoker/RMIAdaptor");    MBeanServerConnection server = (MBeanServerConnection) ctx.lookup("jmx/invoker/RMIAdaptor");    System.out.println(server.getAttribute(new ObjectName("MyDomain:key=property"), "AnAttribute"));    server.invoke(new ObjectName("MyDomain:key=property"), "doSomething", new Object[0], new String[0]); }   // For AS 6.0 (M3) or greater, use the following example import javax.management.MBeanServerConnection; import javax.management.ObjectName; import javax.management.remote.JMXConnector; import javax.management.remote.JMXConnectorFactory; import javax.management.remote.JMXServiceURL;   public void doSomething() throws Exception {    String serverURL = "service:jmx:rmi:///jndi/rmi://localhost:1090/jmxrmi"    String username = null;    String password = null;    HashMap env = new HashMap();    if (username != null && password != null)    {       String[] creds = new String[2];       creds[0] = username;       creds[1] = password;       env.put(JMXConnector.CREDENTIALS, creds);    }    JMXServiceURL url = new JMXServiceURL(serverURL);    JMXConnector jmxc = JMXConnectorFactory.connect(url, env);    // Remember to call jmxc.close() when you are done with server connection.    MbeanServerConnection server = jmxc.getMBeanServerConnection();    System.out.println(server.getAttribute(new ObjectName("MyDomain:key=property"), "AnAttribute"));    server.invoke(new ObjectName("MyDomain:key=property"), "doSomething", new Object[0], new String[0]); }