0

我想计算队列中的消息。

InitialContext ctx = initQueue();
connFactory = (QueueConnectionFactory) ctx.lookup(CF_NAME);
queueConnection = connFactory.createQueueConnection();
queueConnection.start();
queueSession =
                queueConnection.createQueueSession(false, 
QueueSession.AUTO_ACKNOWLEDGE);
        queue = (Queue) ctx.lookup(queueName);

QueueBrowser queueBrowser = queueSession.createBrowser(queue);

但是在这里它停止了------->QueueBrowser queueBrowser = queueSession.createBrowser(queue)

错误消息是：活动会话计数：1：org.wso2.andes.AMQDisconnectedException：服务器关闭连接并且不允许重新连接。javax.jms.JMSException：注册消费者时出错：org.wso2.andes.AMQException：由于 org.wso2.andes.client.AMQSession$6.execute(AMQSession.java:2143) 的类 javax.jms.JMSException 在 org 上唤醒.wso2.andes.client.AMQSession$6.execute(AMQSession.java:2086) 在 org.wso2.andes.client.AMQConnectionDelegate_8_0.executeRetrySupport(AMQConnectionDelegate_8_0.java:323) 在 org.wso2.andes.client.AMQConnection$3.run (AMQConnection.java:655) 在 java.security.AccessController.doPrivileged(Native Method) 在 org.wso2.andes.client.AMQConnection.executeRetrySupport(AMQConnection.java:652) 在 org.wso2.andes.client.failover.FailoverRetrySupport .

4

1 回答 1

0

您能否先创建一个队列，然后按如下方式创建浏览器？

QueueBrowser 浏览器 = queueSession.createBrowser(queueSession.createQueue("test-queue"));

于 2018-08-08T09:53:48.463 回答