I Got the answer, In the above programme i did not start the connection.
__________________________________________________
1) RequestMessage:
import javax.jms.*;
import javax.naming.*;
import java.util.*;
public class RequestMsg
{
public static void main(String args[])
{
QueueConnectionFactory qcf=null;
QueueConnection queueConnection=null;
QueueSession queueSession =null;
Queue queue=null;
TextMessage message=null;
final String MSG_TEXT="This is a
test Message";
TextMessage reply=null;
QueueRequestor queueRequestor=null;
Context ctx= null;
try
{
Hashtable ht= new Hashtable();
ht.put(Context.INITIAL_CONTEXT_FACTORY,"weblogic.jndi.WLInitialContextFactory");
ht.put(Context.PROVIDER_URL,"t3://localhost:7001");
ctx= new InitialContext(ht);
}
catch(NamingException ne)
{
System.out.println("NamingException occured: " + ne);
}
try
{
qcf= (QueueConnectionFactory)ctx.lookup("javax.jms.QueueConnectionFactory");
queue= (Queue)ctx.lookup("Q1");
queueConnection=qcf.createQueueConnection();
queueSession = queueConnection.createQueueSession(false,Session.CLIENT_ACKNOWLEDGE);
}
catch(Exception ne1)
{
System.out.println("NamingException in lookup: " + ne1);
if (queueConnection !=null)
{
try
{
queueConnection.close();
}catch(JMSException ee)
{
}
}
System.exit(1);
}
try
{
queueRequestor= new QueueRequestor(queueSession,queue);
message= queueSession.createTextMessage();
message.setText(MSG_TEXT);
System.out.println("REQUEST: Sending Messages: " + message.getText());
queueConnection.start();
reply=(TextMessage)queueRequestor.request(message);
System.out.println("REQUEST: Reply RECEIVED: "+ reply.getText());
}catch(JMSException je)
{
System.out.println("JMSException occured:" + je);
}
}
}
_________________________________________________
2) ResponseMsg:
import javax.jms.*;
import javax.naming.*;
import java.util.*;
public class ResponseMsg
{
public static void main(String args[])
{
QueueConnectionFactory queueConnectionFactory= null;
QueueConnection queueConnection = null;
QueueSession queueSession= null;
Queue queue=null;
QueueReceiver queueReceiver=null;
TextMessage message=null;
Queue tempQueue=null;
QueueSender replySender= null;
TextMessage reply=null;
final String REPLY_TEXT="Here is that message";
Context ctx=null;
try
{
Hashtable ht= new Hashtable();
ht.put(Context.INITIAL_CONTEXT_FACTORY,"weblogic.jndi.WLInitialContextFactory");
ht.put(Context.PROVIDER_URL,"t3://localhost:7001");
ctx= new InitialContext(ht);
}
catch(NamingException ne)
{
System.out.println("NamingException occured: " + ne);
}
try
{
queueConnectionFactory= (QueueConnectionFactory)ctx.lookup("javax.jms.QueueConnectionFactory");
queue=(Queue) ctx.lookup("Q1");
queueConnection = queueConnectionFactory.createQueueConnection();
queueSession= queueConnection.createQueueSession(false,Session.CLIENT_ACKNOWLEDGE);
}
catch(Exception ne1)
{
System.out.println("Exception in lookup: " + ne1);
if (queueConnection !=null)
{
try
{
queueConnection.close();
}catch(JMSException ee)
{
}
}
System.exit(1);
}
try
{
queueReceiver= queueSession.createReceiver(queue);
queueConnection.start();
message = (TextMessage)queueReceiver.receive();
System.out.println("REPLY : Message Received: " + message.getText());
Queue tq= (Queue)message.getJMSReplyTo();
replySender = queueSession.createSender(tq);
reply= queueSession.createTextMessage();
reply.setText(REPLY_TEXT);
reply.setJMSCorrelationID(message.getJMSMessageID());
System.out.println("REPLY: Sending Reply : "+ reply.getText());
replySender.send(reply);
}
catch(JMSException je)
{
System.out.println("JMSException : " + je);
}
}
}
Regards,
M.S.Raman.