MQSeries.net :: View topic

raja_no_1 · Posted: Thu Nov 20, 2008 2:29 am Post subject:

Hello there!

I am trying to write RHF2 Header using java on a given message.. Having searched this forum I found some snippents of code which should work but unfortunately it doesnt.

I am trying this on windows XP. Can someone please guide me as to where I am going wrong.

I am getting the error => Completeion code 2 Reason code 2334

Which translates to =>
2334 0x0000091e MQRC_RFH_ERROR

============== CODE ===================

import com.ibm.mq.*;
import java.io.*;

public class SimplePut {

private static MQQueueManager qMgr;

public SimplePut() {
super();
}

public static void main(String args[]) {
try {
// create a new instance of the sample program
SimplePut mSender = new SimplePut();

//Queue Maneger name

qMgr = new MQQueueManager("TEST_QUEUEMANAGER");
//Queue Name
String queueName = "INPUT_QUEUE";

int openOptions =MQC.MQOO_OUTPUT | MQC.MQOO_FAIL_IF_QUIESCING | MQC.MQOO_SET | MQC.MQOO_INPUT_AS_Q_DEF ;
MQQueue q = qMgr.accessQueue(queueName,
openOptions, null, null, null);

// call method to send messages
mSender.mPut(qMgr, q);
System.out.println("Message Sent");

// clean up connection
q.close();
qMgr.disconnect();
// }

} catch (MQException ex) {
System.out.println("MQ exception occurred : Completeion code "
+ ex.completionCode + " Reason code " + ex.reasonCode);
}
}
/**
* This method was created in VisualAge.
*
* @param qMgr - a MQ QueueManager object
* @param q - a MQ Queue object
*
*/

public void mPut( MQQueueManager qMgr, MQQueue q) {
try {

// Define a MQ message buffer

MQMessage outMsg = new MQMessage();
outMsg.format = MQC.MQFMT_STRING ;
try {
//outMsg.writeString("message");
buildRFH2Header(outMsg);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

// create message options
MQPutMessageOptions pmo = new MQPutMessageOptions(); // accept defaults
pmo.options = MQC.MQPMO_NONE; // use defaults

q.put(outMsg, pmo); // put the message out on the queue

} catch (MQException ex) {
System.out.println("MQ exception occurred : Completeion code " +
ex.completionCode + " Reason code " +
ex.reasonCode);
}

}

/**
* @param msg
* @return
* @throws IOException
*/
public MQMessage buildRFH2Header(MQMessage msg) throws IOException {

String pubCommand = new String();

pubCommand = "<psc><Command>Publish</Command><Topic>Stock</Topic>" +

"<QMgrName>QFLEXT1</QMgrName><QName>QFLEXT1.A</QName></psc>";

int folderLength = pubCommand.length();

MQMessage theMsg = msg;

theMsg.format = MQC.MQFMT_RF_HEADER_2; // Msg Format

theMsg.writeString(MQC.MQRFH_STRUC_ID); // StrucId

theMsg.writeInt4(MQC.MQRFH_VERSION_2); // Version

theMsg.writeInt4(MQC.MQRFH_STRUC_LENGTH_FIXED_2 + folderLength * 4);

theMsg.writeInt4(MQC.MQENC_NATIVE); // Encoding

theMsg.writeInt4(MQC.MQCCSI_DEFAULT); // CodedCharacterSetId

theMsg.writeString(MQC.MQFMT_NONE); // Format (content)

theMsg.writeInt4(MQC.MQRFH_NO_FLAGS); // Flags

theMsg.writeInt4(1208); // NameValueCCSID = UTF-8

theMsg.writeInt4(folderLength);

theMsg.writeString(pubCommand);

theMsg.writeString("begin payload");

return theMsg;

}

}