MQSeries.net :: View topic

sivaks · Posted: Wed Jan 11, 2012 7:27 am Post subject:

Hi,

I am reading messages from MQ through JavaCompute node(MQInput). After completing process that message, I lookup MQ directly to find out any more messages are available to process. The reason is that i wanted to perform batchInsert to avoid 1 DB call per transaction, since the amount of inserts are really huge. I have posted around 100 messages to MQ. Once the control goes to evaluate method, I am processing the first message. After that, reading the message from MQ directly. I am able to process that message from queue without any issues. This process will be in loop. It will be reading from the queue continously until it reaches its max count. I have set max count as 50. When it starts reading the second message, I get the below exception.

com.ibm.mq.MQException: MQJE001: Completion Code 2, Reason 2033

It clearly indicates that there are no more messages available in the queue. It is not correct, I am able to see the messages in the queue. At that time, i am seeing queue depth as 78, it means that more messages available in that queue.

But I see that, evaluate method of JavaCompute node gets invoked again and process 2 messages and throws the above exception again.

This process continues until it process all the 100 messages in the queue.

I am not able to understand, why it throws that exception after reading 2 messages and starts processing again. I did set WAIT time(variation of 1000/5000/10000 milliseconds), so that it waits for some time to read the message from queue, since MQInput java compute node process it so quickly.

I tried both ways, without WAIT and with WAIT time, still it process the same way. I tried submitting 10 or 50 or 100 messages. All the time, it process only 2 messages at a time. One more point, it is just one thread.

String queueManager = getBroker().getQueueManagerName();
MQQueueManager qMgr = new MQQueueManager(queueManager);
int openOptions = 17;
MQQueue queue = qMgr.accessQueue(QName, openOptions);
MQMessage msg = new MQMessage();
MQGetMessageOptions gmo = new MQGetMessageOptions();
gmo.options = CMQC.MQGMO_WAIT;
gmo.waitInterval = 10000;
for(int i=1; i<= recordCount; i++){
/* keep getting messages until it reaches the recordCount */
queue.get(msg,gmo);
if(msg != null){
String Str = msg.toString();
byte msgLength[]=new byte[msg.getDataLength()];
msg.readFully(msgLength);
String msgFull = new String(msgLength);
processMessage(msgFull);
}
}

Request your input on this.

Regards,
Siva