我需要用 Java 編程語言創(chuàng)建一個 REST 服務(wù)，該服務(wù)接收 JMS 連接工廠的 JNDI 名稱和 JMS 主題的 JNDI 名稱作為輸入，并且應(yīng)該返回此時資源中的消息數(shù)。問題是從 IBM WAS 獲取主題的長度。我知道來自 Oracle 的 TopicBrowser 的存在，您可以使用它獲取主題中的所有消息并計算它們的數(shù)量。但出于某種原因，我們不使用它。我的想法是獲取 SIB Destination queue length 屬性，該屬性位于 Web 控制臺中的 Buses> Bus> Recipients> MyTopic.Space> Publication Points 中。我使用：IBM WAS 9.0。無損檢測。默認消息提供程序。我很樂意接受任何建議。
1 回答
茅侃侃
TA貢獻1842條經(jīng)驗 獲得超22個贊
您可以使用管理客戶端獲取訂閱者的狀態(tài)，例如：
? ? ? ? ? ? ? ? ? ? ? ? ? // 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();
? ? ? ? }
這會產(chǎn)生類似的東西：
默認主題空間深度：2
添加回答
舉報
0/150
提交
取消