MQSeries.net :: View topic

TheDude · Posted: Tue Aug 12, 2003 9:46 am Post subject:

Howdy,

I am running MQ5.3 on WAS 5.0/Linux sending requests to a TPF mainframe. The problem that I am having is messages queueing up on either the xmitq or the reply queue on the app server. no errors are found in the error logs and the channels are still in running status. Also, my application is retreiving messages from the reply queue based on matching the correlID/machineID of the request & reply messages, but when this "stalled" or queueing condition occurs the application times-out with a 2033.

When I try to clear or delete the queue I get a "queue not empty" or "queue in use" message. So far the only way that I have found to get rid of the messages is to stop all channels and stop/start the queue manager -- NOT ACCEPTABLE.

Below is a snippet of the code from my Data Access Object, perhaps there is a coding fix in my application that can be applied.

try {

qMgr = new MQQueueManager(mqValueBean.getQueueManager());

MQQueue targetQueue = qMgr.accessQueue(mqValueBean.getLocalQueue(),mqValueBean.getOutputOptions());

//Put the message on the Queue
targetQueue.put(sendMsgDAO, mqValueBean.getPutMessageOptions());

targetQueue.close();

MQQueue responseData = qMgr.accessQueue(mqValueBean.getReplyQueue(),mqValueBean.getInputOptions());

recvMsgDAO.correlationId = sendMsgDAO.messageId;

CASLoggers.auditLogger().text(IRecordType.TYPE_ERROR, auditClass, auditMethod, "Rcvr" );

responseData.get(recvMsgDAO, mqValueBean.getGetMessageOptions());
responseData.close();

recvMessageSize = recvMsgDAO.getTotalMessageLength();
qMgr.disconnect();

Thanks in advance
The Dude!