MQSeries.net :: View topic - Message mismatch between Request Queue and Response Queue

iamaung · Posted: Tue Jul 27, 2010 7:48 pm Post subject:

We are having very strange problem. Our request message id and the response message from response queue are not the same and all the messages are mismatch. Can anyone help please?

Here is the code we are using. Did we do something wrong?

MQConnectionFactory qconFactory = null;
MQConnection connection = null;
MQSession mqsession = null;
MQQueueSender sender = null;
MQQueue queue = null;
TextMessage msg = null;

MQQueueReceiver qReceiver = null;
MQQueue queue2 = null;
String replyMsg = new String();
TextMessage rplyMsg = null;

try{
qconFactory = (MQConnectionFactory) ctx.lookup("MQPROJECT.PRI.MQCF");
System.out.println("MQConnectionFactory OK.");
writeLogFile("MQConnectionFactory OK.");
} catch (NamingException ne){
System.out.println("MQConnectionFactory Err : "+ne.getMessage());
writeLogFile("MQConnectionFactory Err : "+ne.getMessage());
ne.printStackTrace();
return;
}

try{
connection = (MQConnection) qconFactory.createConnection();
System.out.println("MQConnection OK.");
writeLogFile("MQConnection OK.");
}catch (JMSException jmse) {
System.out.println("MQConnection Err : "+jmse.getMessage());
writeLogFile("MQConnection Err : "+jmse.getMessage());
jmse.printStackTrace(System.err);
return;
}

try{
mqsession = (MQSession) connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
System.out.println("MQSession OK.");
writeLogFile("MQSession OK.");
}catch (JMSException jmse) {
System.out.println("MQSession Err : "+jmse.getMessage());
writeLogFile("MQSession Err : "+jmse.getMessage());
jmse.printStackTrace(System.err);
return;
}

try {
queue = (MQQueue) ctx.lookup("MQREQUEST.ELK.ABC.DEF11");//Request Queue
queue.setTargetClient(1);
//Set TargetClient will assign current MQ request as JMS Queue Message

System.out.println("MQQueue OK.");
writeLogFile("MQQueue OK.");
}catch (NamingException ne) {
System.out.println("MQQueue Err : "+ne.getMessage());
writeLogFile("MQQueue Err : "+ne.getMessage());
ne.printStackTrace(System.err);
return;
}

try {
queue2 = (MQQueue) ctx.lookup("MQREPLY.ELK.ABC.XYZ11");//Reply Queue
System.out.println("MQQueue2 OK.");
writeLogFile("MQQueue2 OK.");
}catch (NamingException ne) {
System.out.println("MQQueue2 Err : "+ne.getMessage());
writeLogFile("MQQueue2 Err : "+ne.getMessage());
ne.printStackTrace(System.err);
return;
}

try {
msg = mqsession.createTextMessage();
System.out.println("CreateMessage OK.");
writeLogFile("CreateMessage OK.");
}catch (JMSException jmse) {
System.out.println("createTextMessage Err : "+jmse.getMessage());
writeLogFile("createTextMessage Err : "+jmse.getMessage());
jmse.printStackTrace(System.err);
return;
}

try {
sender = (MQQueueSender) mqsession.createProducer(queue);
System.out.println("MQQueueSender OK.");
writeLogFile("MQQueueSender OK.");
}catch (JMSException jmse) {
System.out.println("MQQueueSender Err : "+jmse.getMessage());
writeLogFile("MQQueueSender Err : "+jmse.getMessage());
jmse.printStackTrace(System.err);
return;
}

try {
connection.start();
System.out.println("Connection Start OK.");
writeLogFile("Connection Start OK.");
}catch (JMSException jmse) {
System.out.println("ConnectionStart Err : "+jmse.getMessage());
writeLogFile("ConnectionStart Err : "+jmse.getMessage());
jmse.printStackTrace(System.err);
return;
}

try {
msg.setJMSExpiration(2000);
msg.setJMSReplyTo(queue2);

msg.setText(strTxt);
sender.send(msg);
System.out.println("Message Send OK.");
writeLogFile("Message Send OK.");
}catch (Exception e) {
System.out.println("ConnectNSend Err : "+e.getMessage());
writeLogFile("ConnectNSend Err : "+e.getMessage());
e.printStackTrace(System.err);
return;
}

try {
sender.close();
System.out.println("SenderClose OK.");
writeLogFile("SenderClose OK.");
}catch (Exception e) {
System.out.println("MessageSenderClear Err : "+e.getMessage());
writeLogFile("MessageSenderClear Err : "+e.getMessage());
e.printStackTrace(System.err);
return;
}

//==================

try {
qReceiver = (MQQueueReceiver) mqsession.createConsumer(queue2);
System.out.println("MQQueueReceiver OK.");
writeLogFile("MQQueueReceiver OK.");
}catch (JMSException jmse) {
System.out.println("MQQueueReceiver Err : "+jmse.getMessage());
writeLogFile("MQQueueReceiver Err : "+jmse.getMessage());
jmse.printStackTrace(System.err);
return;
}

try {
rplyMsg = (TextMessage)qReceiver.receive(20000);
//msg is sending message and rplyMsg is to receive
rplyMsg.setJMSCorrelationID(msg.getJMSCorrelationID());
replyMsg = rplyMsg.getText();

System.out.println("MessageReceive OK.");
System.out.println("MsgReceive : "+replyMsg);
writeLogFile("MsgReceive : "+replyMsg);
}catch(Exception e) {
System.out.println("ReceiveMessage Err : "+e.getMessage());
writeLogFile("ReceiveMessage Err : "+e.getMessage());
e.printStackTrace(System.err);
return;
}

try {
qReceiver.close();
mqsession.close();
connection.close();
System.out.println("SenderClose OK.");
writeLogFile("SenderClose OK.");
}catch (Exception e) {
System.out.println("MessageSenderClear Err : "+e.getMessage());
writeLogFile("MessageSenderClear Err : "+e.getMessage());
e.printStackTrace(System.err);
return;