MQSeries.net :: View topic

merlin · Posted: Wed Jun 16, 2004 7:57 am Post subject:

Hi,

Hope that someone has come across this scenario and can guide me in the right direction...
Have got a java app talking to MQ, which, so far, has had no problems sending messages to the queue and getting messages from another queue.
Have extended the code now whereby when a message is sent (to a clustered queue as it happens) the app at that end fires back a message to my local queue called "REPLYTOQUEUE" (imaginative, huh?)
The problem I am getting is that the app this end is able to find the correct message amongst those sat on this REPLYTOQUEUE queue as I am using Message and Correlation Ids to check for the right one. However, when I make the 'get' call, although it finds the one required and no exception is thrown, the message remains on the queue after the app has stopped running. What I want is for it to behave 'normally' and consume the message from my REPLYTOQUEUE queue.
Here is the relevant section of java code:

//create new MQMessage obj to receive in reply
MQMessage replyMessage = new MQMessage();
MQGetMessageOptions gmo = new MQGetMessageOptions();
gmo.matchOptions = MQC.MQMO_MATCH_CORREL_ID;
gmo.options = MQC.MQGMO_WAIT;
gmo.waitInterval = waitFor;
replyMessage.correlationId = correlId;
QRunnerLogger.getLogger().info("About to try to get reply message, depth is "+replyQ.getCurrentDepth());
replyQ.get(replyMessage,gmo);
long end = System.currentTimeMillis();
QRunnerLogger.getLogger().info("Got suitable Reply message in "+(end-start)+" ms");

The correlId value has been passed from the value I got earlier in the code when sending out a message. As stated, this works fine apart from not consuming the messages on the in-queue.

Please help...!