MQSeries.net :: View topic - Error while Receiving the message from local queue using JMS

Deepak2003 · Posted: Thu Aug 28, 2003 7:17 am Post subject:

Hi

I am facing problems while receiving the message from local queue. i have MQ Series 5.2 setup on windows and running this code on the same machine using JMS :

The error i am getting is :
================================================================================
The attempt to read the message back again failed, apparently because it wasn't
there
javax.jms.JMSException: Failed to get message back again
at QReceiver1.main(QReceiver1.java:43)
===============================================
But i have two messages in my local queue ?

Here is the outline of my code which i am using to retrieve the message from queue :
+++++++++++++++++++++++++++++++++++++++++++++++
public static void main(String args[])
{
try
{
String factoryName="QCF2";
String queueName="Q3";

Context ctx = initJNDI(icf, url);

QueueConnectionFactory factory =(QueueConnectionFactory) ctx.lookup(factoryName);
Queue queue = (Queue) ctx.lookup(queueName);
ctx.close();
//create JMS objects
QueueConnection connection = factory.createQueueConnection();
QueueSession session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
// code for receiving the message
QueueReceiver queueReceiver = session.createReceiver(queue);

Message inMessage = queueReceiver.receive(1000);

// Check to see if the receive call has actually returned a
// message. If it hasn't, report this and throw an exception...
if( inMessage == null ) {
System.out.println( "The attempt to read the message back again " +
"failed, apparently because it wasn't there");
throw new JMSException("Failed to get message back again");
}

// ...otherwise display the message
System.out.println( "\n" + "Got message"+": "+inMessage);

if( inMessage instanceof TextMessage ) {

// Extract the message content with getText()
String replyString = ((TextMessage) inMessage).getText();
throw new JMSException("Retrieved the wrong type of message");
}
// Closing QueueReceiver
queueReceiver.close();

// end of receive

connection.close();
} catch(Exception e){
e.printStackTrace();
System.exit(1);
}

}
+++++++++++++++++++++++++++++++++++++++++++++++

Please let me know if u have solution to fix the problem. will be really thankfull of you.

Regards
Deepak