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