[jboss-dev-forums] [JBoss Web Development] - HornetQ message count.

[Rishi k]

Rishi k [http://community.jboss.org/people/rishi321] created the discussion

"HornetQ message count."

To view the discussion, visit: http://community.jboss.org/message/588957#588957

--------------------------------------------------------------
|         |        
Hi all,


I am new to HOrnetQ, I need to get message count from HornetQ running on Jboss6Final.But it shows the following error:


ExpiryQueuejava.io.IOException: Failed to retrieve RMIServer stub: javax.naming.NoInitialContextException: Need to specify class name in environment or system property, or as an applet parameter, or in an application resource file:  java.naming.factory.initial    at javax.management.remote.rmi.RMIConnector.connect(RMIConnector.java:338)    at javax.management.remote.JMXConnectorFactory.connect(JMXConnectorFactory.java:248)    at com.jboss.embedded.TestNG.TestCounters.main(TestCounters.java:51)Caused by: javax.naming.NoInitialContextException: Need to specify class name in environment or system property, or as an applet parameter, or in an application resource file:  java.naming.factory.initial    at javax.naming.spi.NamingManager.getInitialContext(NamingManager.java:645)    at javax.naming.InitialContext.getDefaultInitCtx(InitialContext.java:288)    at javax.naming.InitialContext.getURLOrDefaultInitCtx(InitialContext.java:325)    at javax.naming.InitialContext.lookup(InitialContext.java:392)    at javax.management.remote.rmi.RMIConnector.findRMIServerJNDI(RMIConnector.java:1886)    at javax.management.remote.rmi.RMIConnector.findRMIServer(RMIConnector.java:1856)    at javax.management.remote.rmi.RMIConnector.connect(RMIConnector.java:257)    ... 2 more


Here is my code |


public static void main(String[] args){
    Context lContext=null;
    Connection Hconn=null;
    ConnectionFactory Hconnection=null;
    HornetQQueue q=null;
    ObjectName on;
    Hashtable ht = new Hashtable();
    ht.put(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory");
    ht.put(Context.PROVIDER_URL, "xx.xx.xxx.xx");
    ht.put(Context.URL_PKG_PREFIXES, "org.jboss.naming:org.jnp.interfaces");
    try{
        lContext = new InitialContext(ht);
        Hconnection = (ConnectionFactory) lContext.lookup("ConnectionFactory");
        q = (HornetQQueue) lContext.lookup("/queue/ExpiryQueue");
        //System.out.println(q.getQueueName());
        on = ObjectNameBuilder.DEFAULT.getJMSQueueObjectName(q.getQueueName());
        JMXServiceURL url = new JMXServiceURL("rmi", "xx.xx.xxx.xx", 1099, "/jndi/jmx");
        JMXConnector cntor = JMXConnectorFactory.connect(url, ht);
        MBeanServerConnection mbsc = cntor.getMBeanServerConnection();
        JMSQueueControl queueControl = (JMSQueueControl)MBeanServerInvocationHandler.newProxyInstance(mbsc, on, JMSQueueControl.class, false);
        String counters = queueControl.listMessageCounter();
        //System.out.print(counters);
        MessageCounterInfo messageCounter = MessageCounterInfo.fromJSON(counters);         
        System.out.format("%s message(s) in the queue (since last sample: %s)\n",messageCounter.getDepth(),messageCounter.getDepthDelta());
    } catch (Exception e) {
        e.printStackTrace();
    }

}



What seems to be wrong ?
--------------------------------------------------------------

Reply to this message by going to Community
[http://community.jboss.org/message/588957#588957]

Start a new discussion in JBoss Web Development at Community
[http://community.jboss.org/choose-container!input.jspa?contentType=1&containerType=14&container=2112]

-------------- next part --------------
An HTML attachment was scrubbed...
URL: http://lists.jboss.org/pipermail/jboss-dev-forums/attachments/20110222/5e520e4a/attachment.html