MQSeries.net :: View topic - Problem with putQueue.put() operation taking long time

James_O_K · Posted: Thu Aug 24, 2006 4:11 am Post subject:

Hello all,

I have an java app that listens for messages on a queue, processes them and then sends a response. It has several threads running that poll the queue using a static class with a getMessage() method. Ive recently changed this class to use MQGMO_WAIT with an interval of 5 seconds. Since this change when i use the classes putMessage() method it takes a few seconds to perform putQueue.put(message). Is this expected, and if not has anyone seen this before? If not any suggestions as to where to begin looking?

Heres the code associated:

private static int putOpenOptions = MQC.MQOO_FAIL_IF_QUIESCING | MQC.MQOO_OUTPUT;

/**
* Gets an mq message off the queue
* @return MQMessage - cps mq message
* @throws MQException
*/
public static MQMessage getMessage() throws MQException {
final String METHOD_NAME ="getMessage";
//LogHelper.methodEntry(PACKAGE_NAME, CLASS_NAME, METHOD_NAME);
MQMessage returnVal = null;
returnVal = mqGetMessage();
getQueue.get(returnVal , mqGetMessageoptions());
//LogHelper.methodExit(PACKAGE_NAME, CLASS_NAME, METHOD_NAME);
return returnVal;
}

/**
* Sets up get message options for use on get queues
* @return
*/
private static MQGetMessageOptions mqGetMessageoptions() {
MQGetMessageOptions getMessageOptions = new MQGetMessageOptions();
getMessageOptions.matchOptions = MQC.MQMO_NONE;
getMessageOptions.options = MQC.MQGMO_WAIT | MQC.MQGMO_ACCEPT_TRUNCATED_MSG | MQC.MQGMO_FAIL_IF_QUIESCING;
getMessageOptions.waitInterval = waitInterval;
return getMessageOptions;
}

/**
* Puts return message back on to queue
* @param message - message to send
* @param replyToQueueName - reply queue from request message
* @param replyToQmgrName - reply qgmr from request message
* @return
*/
public static void putMessage(MQMessage message, String replyToQueueName, String replyToQmgrName) {
final String METHOD_NAME = "putMessage";
LogHelper.methodEntry(PACKAGE_NAME, CLASS_NAME, METHOD_NAME);
boolean success = false;
try {
// get a handle on dynamic queue each time using replyToQueueName and replyToQmgrName
message.seek(0);
LogHelper.debug(PACKAGE_NAME, CLASS_NAME, METHOD_NAME, "text on put message: " +message.readString(message.getMessageLength()));
putQueue = queueManager.accessQueue(replyToQueueName, putOpenOptions, replyToQmgrName, null, null);
putQueue.put(message);
putQueue.close();
success = true;
putQueue = null;

} catch(MQException e) {
LogHelper.error(PACKAGE_NAME, CLASS_NAME, METHOD_NAME, e.getMessage());
e.printStackTrace();
CPSCommunicatorHelper.sendSupportEmail(PACKAGE_NAME,
CLASS_NAME, METHOD_NAME,
CPSConstants.EMAIL_SUBJECT_ERROR,
"Exception caught: " + e.getMessage(),
CPSConstants.getEmailServer(),
CPSConstants.getEmailAlertAddress());
} catch (IOException ioe){
LogHelper.error(PACKAGE_NAME, CLASS_NAME, METHOD_NAME, ioe.getMessage());
ioe.printStackTrace();
CPSCommunicatorHelper.sendSupportEmail(PACKAGE_NAME,
CLASS_NAME, METHOD_NAME,
CPSConstants.EMAIL_SUBJECT_ERROR,
"Exception caught: " + ioe.getMessage(),
CPSConstants.getEmailServer(),
CPSConstants.getEmailAlertAddress());
}
LogHelper.methodExit(PACKAGE_NAME, CLASS_NAME, METHOD_NAME);
//return success;
}

/**
* Create a get message
* @return MQMessage - basic get message
*/
private static MQMessage mqGetMessage() {
MQMessage message = new MQMessage();
message.messageId = MQC.MQMI_NONE;
message.correlationId = MQC.MQCI_NONE;
return message;
}