java - 计算队列中的消息(以编程方式)-Jboss 7

Question

AS:Jboss 7

假设我在文件中定义了一个队列:

{JBOSS7_HOME}/standalone/configuration/standalone.xml

<jms-queue name="myQueue">
    <entry name="java:/queue/myQueue"/>
    <durable>true</durable>
</jms-queue>

问题:

如何以编程方式检查队列中的消息数量？

Answer 1

您可以使用以下代码。

String jndiFactory="org.jboss.naming.remote.client.InitialContextFactory";
String jmsFactory="jms/RemoteConnectionFactory";
String queueName="jms/queue/MyQueue";
String providerUrl="remote://ipAddress:4447";
String username="testuser";
String password="testpassword";

Session qsession = null;
Connection qcon = null;
QueueBrowser browser = null;

ConnectionFactory qconFactory;
InitialContext ctx = null;
int depth=0;
try{
    Hashtable<String, String> env = new Hashtable<String, String>();
    env.put(Context.INITIAL_CONTEXT_FACTORY, jndiFactory);
    env.put(Context.PROVIDER_URL, providerUrl);
    env.put(Context.SECURITY_PRINCIPAL, username);
    env.put(Context.SECURITY_CREDENTIALS, password);

    ctx = new InitialContext(env);
    qconFactory = (QueueConnectionFactory) ctx.lookup(jmsFactory);
    qcon = qconFactory.createConnection(username, password);
    qsession = qcon.createSession(false, Session.AUTO_ACKNOWLEDGE);
    Queue queue = (Queue) ctx.lookup(qName);
    browser = qsession.createBrowser(queue);
    qcon.start();
    for (Enumeration e = browser.getEnumeration(); e.hasMoreElements();e.nextElement()) {
        depth++;
    }
}catch(Exception e){
    System.out.println("Some exception :"+e.toString());
}finally {
    try {
        if(qcon !=null)
            qcon.close();
        if(qsession !=null)
            qsession.close();
        if(browser !=null)
            browser.close();
    } catch (Exception e) {
        System.out.println("Some exception :"+e.toString());
    }
}