Ashirbad Kumar

Hi,

Can some one explain me the actually explaination of " queueConnectionFactory = (QueueConnectionFactory)
jndiContext.lookup("QueueConnectionFactory");"
this statement in the above program.

Or if possible please advice some link where i get a proper explaination of this statement.

Help will be appreciated and will be grateful.

Thanks ,
Ashirbad

Paul Clapham wrote:It's lines 49 to 54 which are your problem, clearly, since that's where the error message comes from. I expect you have to provide some kind of configuration entry to tell the naming factory where the ORB is located.

Whether you have to do that in code or in some kind of Websphere configuration, I have no idea. Perhaps the documentation for your ORB would tell you that.

Hi Paul,

Thanks a lot for your help.

Please send me one simple JMS program as i am a learner now.

And I need to run the program in Eclipse.

So guide me for the same.

I will be grateful to you for your kind help.

Thanks and Regards,
Ashirbad

I am getting this error whenever i am trying to run the JMS program.

Please refer to the below program and help me out of it:
import java.util.Hashtable; import javax.jms.*; import javax.naming.*; import com.sun.xml.internal.fastinfoset.sax.Properties; public class jms_8 { /** * Main method. * * @param args the queue used by the example and, * optionally, the number of messages to send */ public static void main(String[] args) { String queueName = null; Context jndiContext = null; QueueConnectionFactory queueConnectionFactory = null; QueueConnection queueConnection = null; QueueSession queueSession = null; Queue queue = null; QueueSender queueSender = null; TextMessage message = null; final int NUM_MSGS; if ( (args.length < 1) || (args.length > 2) ) { System.out.println("Usage: java SimpleQueueSender " + "<queue-name> [<number-of-messages>]"); System.exit(1); } queueName = new String(args[0]); System.out.println("Queue name is " + queueName); if (args.length == 2){ NUM_MSGS = (new Integer(args[1])).intValue(); System.out.println(NUM_MSGS); } else { NUM_MSGS = 1; } /* * Create a JNDI API InitialContext object if none exists * yet. */ try { Hashtable p = new Hashtable(); p.put("java.naming.factory.initial", "com.sun.jndi.cosnaming.CNCtxFactory"); /*p.put("java.naming.provider.url", "iiop://192.168.75.214:9010");*/ jndiContext = new InitialContext(p); } catch (NamingException e) { System.out.println("Could not create JNDI API " + "context: " + e.toString()); System.exit(1); } /* * Look up connection factory and queue. If either does * not exist, exit. */ try { queueConnectionFactory = (QueueConnectionFactory) jndiContext.lookup("QueueConnectionFactory"); queue = (Queue) jndiContext.lookup(queueName); System.out.println(queue); } catch (NamingException e) { System.out.println("JNDI API lookup failed: " + e.toString()); System.exit(1); } /* * Create connection. * Create session from connection; false means session is * not transacted. * Create sender and text message. * Send messages, varying text slightly. * Send end-of-messages message. * Finally, close connection. */ try { queueConnection = queueConnectionFactory.createQueueConnection(); queueSession = queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE); queueSender = queueSession.createSender(queue); message = queueSession.createTextMessage(); for (int i = 0; i < NUM_MSGS; i++) { message.setText("This is message " + (i + 1)); System.out.println("Sending message: " + message.getText()); queueSender.send(message); } /* * Send a non-text control message indicating end of * messages. */ queueSender.send(queueSession.createMessage()); } catch (JMSException e) { System.out.println("Exception occurred: " + e.toString()); } finally { if (queueConnection != null) { try { queueConnection.close(); } catch (JMSException e) {} } } } }

A quick help will be appreciated and will be thankful to it.