MQSeries.net :: View topic - create and populate message with MQRFH2 header from java

datspats · Posted: Fri Apr 13, 2007 5:19 am Post subject:

Hi all,

I want create and populate message with MQRFH2 header from java program and put on queue and I want to put any data e.g. filename into <usr> folder of the MQRFH2 header.
e.g. <usr><filename>abc.txt<filename><usr>

the piece code as below

byte[] strDatabytes = strRecord.getBytes();
//strRecord is actual payload

String s1 = "";
s1 = s1.concat("<mcd>");
s1 = s1.concat("</mcd>");

String s2 = "";
s2 = s2.concat("<jms>");
s2 = s2.concat("</jms>");

String s = "";
s = s.concat("<usr>");
s = s.concat("<filename>");
s = s.concat("abc.txt");
s = s.concat("</filename>");
s = s.concat("<fileDATE>");
s = s.concat("13-April-2007");
s = s.concat("</fileDATE>");
s = s.concat("</usr>");

int rfhStrucLength = 0;
rfhStrucLength += MQC.MQRFH_STRUC_LENGTH_FIXED_2;

while(s1.getBytes().length % 4 != 0) {
s1 += " ";
}
rfhStrucLength += s1.getBytes().length;

while(s2.getBytes().length % 4 != 0) {
s2 += " ";
}
rfhStrucLength += s2.getBytes().length;

while(s.getBytes().length % 4 != 0) {
s += " ";
}
rfhStrucLength += s.getBytes().length;

//rfhStrucLength += 12; //for storing namevalue length
rfhStrucLength += strDatabytes.length;

mymsg.format = MQC.MQFMT_RF_HEADER_2;
mymsg.writeString(MQC.MQRFH_STRUC_ID); //StrucID
mymsg.writeInt4(MQC.MQRFH_VERSION_2); //Version
mymsg.writeInt4(rfhStrucLength); //StrucLength
mymsg.writeInt4(MQC.MQENC_NATIVE); //Encoding
mymsg.writeInt4(MQC.MQCCSI_INHERIT); //CodedCharSetID
mymsg.writeString(MQC.MQFMT_NONE); //Format
mymsg.writeInt4(MQC.MQRFH_NO_FLAGS); //Flags
mymsg.writeInt4(1208); //NameValueCCSID*/
mymsg.writeInt4(s1.getBytes().length); //NameValueLength <mcd>
mymsg.writeString(s1); //NameValueData <mcd>
mymsg.writeInt4(s2.getBytes().length);//NameValueLength <jms>
mymsg.writeString(s2); //NameValueData <jms>
mymsg.writeInt4(s.getBytes().length);//NameValueLength <usr>
mymsg.writeString(s); //NameValueData
mymsg.write(strDatabytes); //Actual Message Data
myqueue.put(mymsg,pmo); //putting message on queue

Please let me know where I m going wrong as When I read the message from queue using "rfhutil" I don't get the require payload (actual) in the data section. I also get the warning message from rfhutil as invalid length rfh header area while reading the message from queue. But i can see <usr> folder populated with required details.

waiting for response.
Thanks & Regards