MQSeries.net :: View topic - Temporary queue problem time out before recieving the messag

usman.usmani@gmail.com · Posted: Sat Sep 16, 2006 4:49 am Post subject:

Hi,

I am using WAS 6.0.2.11. I am using default messages to communicate
between applications. I need to communicate synchronously between two
services/application deployed A and B. when i am sending a message from
A to B to the destination B listens to I create a temporary queue and
from A and set it as JMSReplyTo destination send it to B. B sends me
message successfully where as A times out imediately after I send the
message irrespective of the timeout i specify although i am listening message using the following code. Can
any one tell me the solution or workarround.

Following is the code that I use at A.

InitialContext context = null;
try {
context = new InitialContext();
ConnectionFactory factory = (ConnectionFactory)
context.lookup("jms/QCFMQGateWay");
Destination destination = (Destination)
context.lookup("jms/MQGWQueue");
Connection connection = factory.createConnection();
Session session =
connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
MessageProducer producer = session.createProducer(destination);
Destination replyQueue = session.createTemporaryQueue();
BytesMessage message = session.createBytesMessage();
message.setJMSReplyTo(replyQueue);
MessageConsumer replyConsumer = session.createConsumer(replyQueue);
byte [] bytes =
ObjectSerializer.serializeObject(transferObjectBase);
message.writeBytes(bytes);
producer.send(message);

System.out.println("=======================================================Â====");
System.out.println("The connection state is " + connection);
System.out.println("Listening on temporary destination = " +
replyQueue);
System.out.println("=======================================================Â====");
connection.start();
BytesMessage msg = (BytesMessage)replyConsumer.receive(60000);
System.out.println("=======================================================Â====");
System.out.println("The connection state is " + connection);
System.out.println("Message revieved from replyQueue = " + msg);
System.out.println("=======================================================Â====");
if(msg!=null)
{
String reply = getBodyAsString(msg);
System.out.println("The confirmation reply message is " + msg);
if(reply == null || reply.trim().equals(""))
throw new CommunicationException("Unidentified confiramtion reply
format");
else if(reply.equals("Failed"))
throw new CommunicationException("Failed to send request. Please
check the logs");

}else
throw new CommunicationException("Failed to recieve confirmation
message from gateway");

} catch (NamingException e) {

throw new CommunicationException("Cannot find initial Context" ,e);
} catch (JMSException e) {

throw new CommunicationException("Error Occured",e);
} catch (IOException e) {
throw new CommunicationException("cannot serialize object",e);
}

Following is the code at service B that sends a sync response

Destination dest = msg.getJMSReplyTo();

if (dest!=null){

log.debug("reply
destination is :"+dest);

InitialContext ctx = new
InitialContext();

/****

*

* specify the connection factory
name

*/

QueueConnectionFactory factory =
(QueueConnectionFactory)ctx.lookup("jms/QCFMQGateWay");

// create a connection and session

Connection connection =
factory.createQueueConnection();

log.debug("connection in MQGateway
is "+connection);

Session session =
connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

MessageProducer producer =
session.createProducer(dest);

BytesMessage byteReplyMsg =
session.createBytesMessage();

byteReplyMsg.writeBytes(replymsg.getBytes());

producer.send(msg);

log.debug("the reply message has
been sent to :"+dest);

}else {

/// to do send to a
specified destination for errors

log.debug("destination
is null ---- not going to send");

}
_________________
Usmani