MQSeries.net :: View topic - problem connecting MQSever using client JMS

venkat.rajm · Posted: Thu Jan 26, 2006 1:50 pm Post subject:

Hi All,

I am new to the Websphere MQ , i am using Wesphere MQ Client .when i am using core java classes i am getting messages with out any exception . when i am using JMS i am getting some error , any one can help me to over this problem. here i am using point-to-point connection.

operating environment is:

Windows XP
websphere application server 5.1
websphere MQServer 6.0
wesphere MQClient 6.0

In websphere Application server, i have setted Additional Properties for WebSphere MQ Queue Connection Factories and WebSphere MQ Queue Destinations

Here my code :

import java.util.*;
import javax.jms.*;
import javax.jms.Queue;
import javax.naming.directory.*;
import javax.naming.*;

public class PtpReceiver1 {

public static void main(String[] args) {
String queueName = "TRITEKL;
String qcfName = "TRITEKCF" ;--WebSphere MQ Queue Connection Factories ----here i am not sure which ine i have to provide.
Context jndiContext = null;
QueueConnectionFactory queueConnectionFactory= null;
QueueConnection queueConnection = null;
QueueSession queueSession = null;
Queue queue = null;
QueueReceiver queueReceiver = null;
TextMessage message = null;
String providerUrl = "iiop://IMCTRITEK:1414/TRITEKQMGR" ;
String initialContextFactory = "com.ibm.websphere.naming.WsnInitialContextFactory";
try{

Hashtable env = new Hashtable() ;
env.put(Context.INITIAL_CONTEXT_FACTORY, initialContextFactory) ;
env.put(Context.PROVIDER_URL , providerUrl );
jndiContext = new InitialDirContext(env);
queueConnectionFactory = (QueueConnectionFactory)jndiContext.lookup(qcfName);

queue = (Queue)jndiContext.lookup(queueName);

queueConnection = queueConnectionFactory.createQueueConnection();
queueConnection.start();
queueSession = queueConnection.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
queueReceiver = queueSession.createReceiver(queue);
boolean eom = true;
while (eom) {
Message m = queueReceiver.receive(1);
if (m != null) {
if (m instanceof TextMessage) {
message = (TextMessage) m;
System.out.println("Reading message: " +message.getText()); }
else {

break;
}
}
else eom = false;
}
queueConnection.close();
}
catch(Exception e){
e.printStackTrace();
}
}
}

Here my Exception:

javax.naming.NoInitialContextException: Cannot instantiate class: com.ibm.websphere.naming.WsnInitialContextFactory [Root exception is java.lang.ClassNotFoundException: com.ibm.websphere.naming.WsnInitialContextFactory]
at javax.naming.spi.NamingManager.getInitialContext(Unknown Source)
at javax.naming.InitialContext.getDefaultInitCtx(Unknown Source)
at javax.naming.InitialContext.init(Unknown Source)
at javax.naming.InitialContext.<init>(Unknown Source)
at javax.naming.directory.InitialDirContext.<init>(Unknown Source)
at PtpReceiver1.main(PtpReceiver1.java:42)
Caused by: java.lang.ClassNotFoundException: com.ibm.websphere.naming.WsnInitialContextFactory
at java.net.URLClassLoader$1.run(Unknown Source)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(Unknown Source)
at java.lang.ClassLoader.loadClass(Unknown Source)
at sun.misc.Launcher$AppClassLoader.loadClass(Unknown Source)
at java.lang.ClassLoader.loadClass(Unknown Source)
at java.lang.ClassLoader.loadClassInternal(Unknown Source)
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Unknown Source)
at com.sun.naming.internal.VersionHelper12.loadClass(Unknown Source)
... 6 more

Any one can help me to over come this problem.Thanks in Advance.

Venkat.