[jboss-user] [Messaging, JMS & JBossMQ] - Re: import org.jboss.mq.server.jmx.Queue

[milind.uc]

yes ,, I think I am doing the mistake while using it actually I am using it fom simple pojo class.....



  | public class Sender_Count 
  | {
  | 	
  | 
  | 	
  | 
  | 
  | 	public static QueueConnectionFactory	factory		= null;
  | 	public static QueueConnection			connection	= null;
  | 	public static QueueSession				session		= null;
  | 	public static QueueSender				sender		= null;
  | 	public static Context					ctx			= null;
  | 	public static javax.jms.Queue			queue		= null;
  | 	public static TextMessage				message		= null;
  | 	public static ConnectionMetaData		metadata	= null;
  |     public static Queue						obj			= null;
  | 	
  | 	//public static JMSQueue  queue  = null;
  | 	
  | 	
  | 	public static void main(String[] args)
  | 	{
  | 
  | 		/*
  | 		 * Hashtable env = new Hashtable(); env.put(Context.INITIAL_CONTEXT_FACTORY,"org.jnp.interfaces.NamingContext"); env.put(Context.PROVIDER_URL,"jnp://localhost:1099"); env.put(Context.URL_PKG_PREFIXES,"jboss.naming:org.jnp.interfaces");
  | 		 */  
  | 		
  | 		
  | 		
  | 		Hashtable env = new Hashtable();
  | 
  | 		env.put(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory");
  | 		env.put(Context.PROVIDER_URL, "jnp://localhost:1099");
  | 		env.put(Context.URL_PKG_PREFIXES, "jboss.naming:org.jnp.interfaces");
  | 
  | 		
  | 		
  | 		try
  | 		{
  | 			ctx = new InitialContext(env);
  | 			factory = (QueueConnectionFactory) ctx.lookup("UIL2ConnectionFactory");
  | 			connection = factory.createQueueConnection();
  | 			session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
  | 			queue = (javax.jms.Queue) ctx.lookup("queue/C");
  | 			sender = session.createSender(queue);
  | 			connection.start();
  | 			message = session.createTextMessage();
  | 			message.setText("Bajirao_Mastani");
  | 			sender.send(message);
  | 			
  | 	
  | 			
  | 			
  | 
  | 	String domain = "jboss.mq.destination";
  | 	String service = "service=Queue";
  | 	String name = "name=queue/C";
  | 		
  | 	String stringObjectName = domain + ":" + service + "," + name;
  | 		
  | 	MBeanServer server = MBeanServerLocator.locateJBoss();
  | 		
  | 	try{
  | 		ObjectName queueObjectName = ObjectName.getInstance(stringObjectName);
  | 		
  | 		org.jboss.mq.server.jmx.QueueMBean queueMBean = 
  | 			(org.jboss.mq.server.jmx.QueueMBean) MBeanServerInvocationHandler.newProxyInstance(
  | 					server,
  | 					queueObjectName,
  | 					org.jboss.mq.server.jmx.QueueMBean.class,
  | 					false
  | 				);
  | 		
  | 		logger.info("queue depth: " + queueMBean.getQueueDepth());
  | 		
  | 	}catch (Exception e){
  | 		logger.info("cannot get depth of the queue: " + e.getMessage(),e);
  | 	}		
  | 			
  | 		    
  | 		}
  | 		catch (NamingException e)
  | 		{
  | 			e.printStackTrace();
  | 		}
  | 		catch (JMSException se)
  | 		{
  | 			se.printStackTrace();
  | 		}
  | 		catch (ClassCastException ce)
  | 		{
  | 			ce.printStackTrace();
  | 		}
  | 
  | 	}
  | }
  | 
  | 


I think i  am doing something wrong by calling it in above fashion from simple pojo class...Iam in trouble because of that locateJboss() so  help me.

Thanks :)



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

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