MQSeries.net :: View topic

Prasi · Posted: Mon Dec 09, 2013 2:00 pm Post subject:

Hi,

I am writing the below code in Java compute node: I am iterating to a collection of queues which have the status as either AVAILABLE/LOCKED.
When I see a queue to have a queue which has a message written as "LOCKED", I should read the message and update as "AVAILABLE". This is happening for some 10 tests. And after 12,13 test,the queue is not writing the "AVAILABLE" message to it. The queue is getting read and not writing "AVAILABLE" message to it. Is there any problem with the below code?

try
{
int openOptions=CMQC.MQOO_INPUT_SHARED | CMQC.MQOO_BROWSE;
MQQueue locQueue=qMgr.accessQueue(statusQueue, openOptions);
MQGetMessageOptions gmo=new MQGetMessageOptions();
locQueue.get(msg,gmo);
locQueue.close();
ch(MQException ex) {
System.out.println("An error occurred during the get operation:" + "CC = " + ex.completionCode + "RC = " + ex.reasonCode);
System.out.println("Cause exception:" + ex.getCause() );
}
String msgText=msg.readStringOfCharLength(msg.getMessageLength());
System.out.println("The message in queue is"+msgText);
if ((inUse==true) && (msgText.equalsIgnoreCase("LOCKED")))
{
s.setStatus(false);
int openOptions1 = CMQC.MQOO_INPUT_AS_Q_DEF | CMQC.MQOO_OUTPUT ;
MQQueue locQueue = qMgr.accessQueue(statusQueue,openOptions1);
MQMessage msgtoput = new MQMessage();
MQPutMessageOptions pmo = new MQPutMessageOptions();
String msgtowrite =("AVAILABLE");
msgtoput.writeString(msgtowrite);
locQueue.put(msgtoput, pmo);
locQueue.close();
}