[jboss-user] [JBoss Messaging] - Re: Number of topic subscriptors

[mskonda]

Here's the method that would do what you need.


  | private void testSubscriptionsList(String destName, String type) throws Exception {
  | 
  | 		QueueMBean queueMBean = null;
  | 		TopicMBean topicMBean = null;
  | 		
  | 		try {
  | 			//find the mbean server
  | 			mBeanServer  = (MBeanServerConnection) new InitialContext().lookup("jmx/invoker/RMIAdaptor");
  | 
  | 			// create the relevant ON 
  | 			// Here type equals to Queue or Topic and 
  | 			// destName equals to name of the destination, for example testTopic
  | 			
  | 			serverObjectName = new ObjectName(
  | 					"jboss.messaging.destination:service=" + type + ",name="
  | 							+ destName);
  | 			
  | 			// create either queueMBean or topicMBean
  | 			if (type.equalsIgnoreCase("Queue")) {
  | 
  | 				queueMBean = (QueueMBean) MBeanServerInvocationHandler
  | 						.newProxyInstance(mBeanServer, serverObjectName,
  | 								QueueMBean.class, false);
  | 
  | 			} else if (type.equalsIgnoreCase("Topic")) {
  | 
  | 				topicMBean = (TopicMBean) MBeanServerInvocationHandler
  | 						.newProxyInstance(mBeanServer, serverObjectName,
  | 								TopicMBean.class, false);
  | 			}
  | 
  | 		} catch (NamingException e) {
  | 			logger.warn("NamingException:" + e.getMessage());
  | 			logger.error(e);
  | 		} catch (Exception e) {
  | 			logger.info("Exception:" + e.getMessage());
  | 			logger.error(e);
  | 		}
  | 		
  | 		// once you get the relevant MBean, invoke
  | 		// the appropriate operations. 
  | 		// For example, to list the subscription on the topic
  | 		// do this:
  | 		List subs = topicMBean.listAllSubscriptions();
  | 		
  | 		// iterate through the list..
  | 	}

View the original post : http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4036447#4036447

Reply to the post : http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=4036447