MQSeries.net :: View topic

texan · Posted: Thu Feb 26, 2004 1:58 am Post subject:

I am new to JMS Programming. I have a mq server installed on my machine(version 5.3, Windows XP). I am using file based JNDI to lookup mq objects. I wrote the following porogram to put a message on queue, I am n't getting any exceptions but I can't see the message on Queue? Can somebody help in debugging this? Thanx in advance.

Here is the code:

package com.test.jms;

import java.util.Hashtable;

import javax.jms.DeliveryMode;
import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

public class MyJMSSender {

/**
* Constructor for MyJMSSender.
*/
public MyJMSSender() {
super();
}

public Context getContext(){
Hashtable hashtable = new Hashtable();
hashtable.put(Context.INITIAL_CONTEXT_FACTORY,
"com.sun.jndi.fscontext.RefFSContextFactory");
hashtable.put(Context.PROVIDER_URL,"file://C:/Program Files/IBM/WebSphere MQ/Java/JNDI/jms");
Context context = null;
try{
context = new InitialContext(hashtable);
}catch(NamingException ne){
ne.printStackTrace();
}

return context;
}

public Object getJMSObject(String jndiName){
Context context = getContext();
if(context == null){
return null;
}

Object object = null;
try{
object = context.lookup(jndiName);
}catch(NamingException ne){
ne.printStackTrace();
}
return object;
}

public int sendMessage(String message){
Object obj = getJMSObject("myQCF");
if(obj != null){
System.out.println(obj.getClass());
}
//lookup QueueConnectionFactory
QueueConnectionFactory queueConnectionFactory =
(QueueConnectionFactory)getJMSObject("myQCF");
if(queueConnectionFactory == null){
System.out.println("Could n't get QueueConnectionFactory");
return -1;
}else{
System.out.println("QueueConnectionFactory Object obtained from JNDI..");
}

//look up queue name to put a message on it.
Queue requestQueue = (Queue)getJMSObject("myFirstQueue");
if(requestQueue == null){
System.out.println("Could n't get Queue");
return -1;
}else{
System.out.println("Queue Object obtained from JNDI..");
}

QueueConnection queueConnection = null;
try{
System.out.println(requestQueue.getQueueName());
//create QueueConnection.
queueConnection = queueConnectionFactory.createQueueConnection();
System.out.println("QueueConnection object created...");

//start queue connection
queueConnection.start();
System.out.println("Queue Connection Started..");

//create Queue Session
QueueSession queueSession = queueConnection.
createQueueSession(true,0);
System.out.println("QueueSession created..");

//create Sender
QueueSender queueSender = queueSession.
createSender(requestQueue);
System.out.println("QueueSender created..");

//create mesage object that you want to send
TextMessage textMessage = queueSession.createTextMessage();

textMessage.setText(message);
queueSender.send(textMessage,DeliveryMode.PERSISTENT,5,0);
System.out.println("Send Completed..");
System.out.println("Message id is:"+textMessage.getJMSMessageID());
}catch(JMSException je){
je.printStackTrace();
return -1;
}catch(Exception e){
e.printStackTrace();
}finally{
//close objects
try{
if(queueConnection != null){
System.out.println("Closing Queue Connection...");
queueConnection.stop();
queueConnection.close();
queueConnection = null;
System.out.println("Queue Connection Closed...");
}
}catch(JMSException je){
System.out.println("Exception while cleaning JMS Connection object");
}
}

return 0;

}

public static void main(String[] args) {
MyJMSSender sender = new MyJMSSender();
int retValue = sender.sendMessage("Hello, World");
System.out.println(retValue);
}
}