如何在IBM WAS上获取jms主题中的当前消息数

Question

我需要用 Java 编程语言创建一个 REST 服务，该服务接收 JMS 连接工厂的 JNDI 名称和 JMS 主题的 JNDI 名称作为输入，并且应该返回此时资源中的消息数。问题是从 IBM WAS 获取主题的长度。

我知道来自 Oracle 的 TopicBrowser 的存在，您可以使用它获取主题中的所有消息并计算它们的数量。但出于某种原因，我们不使用它。

我的想法是获取 SIB Destination queue length 属性，该属性位于 Web 控制台中的 Buses> Bus> Recipients> MyTopic.Space> Publication Points 中。

我使用：
IBM WAS 9.0。无损检测。
默认消息提供程序。

我很乐意接受任何建议。

Answer 1

您可以使用管理客户端获取订阅者的状态，例如：                          // Start by querying the objectName of the Publication Point (Topic Space on a specific node).         AdminClient adminClient = AdminClientFactory.createAdminClient(connectProps);         StringBuffer oNameQuery= new StringBuffer();                 oNameQuery.append(adminClient.getDomainName()).append(":*");         oNameQuery.append(",type=").append("SIBPublicationPoint");         oNameQuery.append(",name=").append("Default.Topic.Space");         oNameQuery.append(",node=").append(nodeName);          oNameQuery.append(",process=").append("server1");          oSet= adminClient.queryNames(new ObjectName(oNameQuery.toString()), null);          ObjectName defaultTopicSpaceOn = (ObjectName) oSet.iterator().next();         System.out.println("Default.Topic.Space ObjectName:"+defaultTopicSpaceOn);        // Then look at each subscription storing messages in the Publication Point.        Long depth = (Long) adminClient.invoke (defaultTopicSpaceOn, "getDepth", null, null);        System.out.println("DefaultTopicSpace Depth:"+depth+"\n");        SIBSubscription[] subscriptions = (SIBSubscription[]) adminClient.invoke (defaultTopicSpaceOn, "getSubscriptions", null, null);        for (SIBSubscription subscription : subscriptions) {          System.out.print("DefaultTopicSpace Subscription:"+subscription.getName()                              +" Id:"+subscription.getId()                             +" SubscriberId:"+subscription.getSubscriberId()                             +" Selector:"+subscription.getSelector()                             +" Depth:"+subscription.getDepth());          for (String topicName: subscription.getTopics())            System.out.print(" Topic:"+topicName);          System.out.println();        }这会产生类似的东西：默认主题空间深度：2