MQSeries.net :: View topic - Problems with MQPUT while doing Segmentation

balamurali · Posted: Thu Sep 04, 2003 6:41 am Post subject:

Hello

I have tried to send a 8MB message with segment size of 2MB (4 segments). I am using base java classes of MQSeries. For testing purposes I am trying to read the 8MB file and internally chunking it and then invoking the MQPUT with all the MQPUTOPTIONS as given in the IBM Mq manuals.

I am running it on Windows NT, what I observed is after putting the first two segments (amounting to 4MB) it crashes with the following exception MQJE001: Completion Code 2, Reason 2102 (This is actually insufficient system resources).

I thought this exception is because of the maxmesagelength attribute in the queue and the queue manager I anyway increased it to 10MB. Still the same problem persists. I have pasted the relevant section of the code below. Would greatly appreciate your responses

class NQCalls{
public void putQueue (String host, String appID, String msg, int msgLen, boolean isLastSeq) throws Exception
{
MQMessage mqMsg;
mqMsg = new MQMessage();
mqMsg.setVersion(MQC.MQMD_VERSION_2);
mqMsg.format = MQC.MQFMT_STRING;
//mqMsg.messageType = MQC.MQMT_REQUEST;
mqMsg.applicationIdData = appID;
mqMsg.priority = m_priority;

mqMsg.characterSet = 1208; //UTF-8
mqMsg.write(msg.getBytes("UTF8"));

MQPutMessageOptions pmo = new MQPutMessageOptions();
pmo.options = MQC.MQPMO_LOGICAL_ORDER;

if (m_msgID != null)
mqMsg.messageId = m_msgID.getBytes();

if (isLastSeq)
mqMsg.messageFlags = MQC.MQMF_LAST_SEGMENT | MQC.MQMF_SEGMENTATION_ALLOWED;
else
mqMsg.messageFlags = MQC.MQMF_SEGMENT | MQC.MQMF_SEGMENTATION_ALLOWED;

System.out.println("Before put message");
m_queue.put(mqMsg, pmo);
System.out.println("After put message");

}

}

//The Code which calls to put in the queue

FileChunker aChunker = new FileChunker(fileName); // A piece of code which splits the file into managable byte chunk
byte[] outArray = new byte[FileChunker.CHUNK_SIZE];
for(int i=0;i<aChunker.getNoOfChunks()-1;i++)
{
outArray = aChunker.getNextChunk();
String msg = new String(outArray);
mqCalls1.putQueue("", "APPID", msg,msglen, false);
}
outArray = aChunker.getNextChunk();
String msg = new String(outArray);
mqCalls1.putQueue("", "APPID", msg,msglen,true);
mqCalls1.closeQueue("");