MQSeries.net :: View topic - Publish message from a C#

2YanivYuzis · Posted: Wed Nov 14, 2007 1:40 pm Post subject:

Hello.

I'm trying to send a publish message, in order to publish it with the message broker pub/sub.
I'm using MQ 6.0.2.2.
This is a C# application, using MQ client library.

I thought about two ways for doing that:
1- Send a string message to a queue, with a property that says which topic, and handle all of the RFH thing in the message broker.

But I don't know how to attach property to a string message.

2- Build a RFH2 message for a stright publish in the message broker.
But I'm stuch with the code:

// Put the next message to the queue
mqMsg = new MQMessage();
mqPutMsgOpts = new MQPutMessageOptions();

String message = "ET ISSUE";
System.Text.ASCIIEncoding encoding = new System.Text.ASCIIEncoding();
Byte[] bMessage = encoding.GetBytes(message);

String RFH2_STRUCID_DEFAULT = MQC.MQRFH_STRUC_ID;
int RFH2_VERSION_DEFAULT = MQC.MQRFH_VERSION_2;
int RFH2_STRUCLENGTH_DEFAULT = 36;
int RFH2_ENCODING_DEFAULT = MQC.MQENC_NATIVE;
int RFH2_CODEDCHARSETID_DEFAULT = 1208;
String RFH2_FORMAT_DEFAULT = MQC.MQFMT_RF_HEADER_2;
int RFH2_FLAGS_DEFAULT = MQC.MQRFH_NO_FLAGS;
int RFH2_NAMEVALUECCSID_DEFAULT = 1208;
String MCD_DATA_DEFAULT = "<mcd><Msd>jms_text</Msd></mcd>";
String FORMAT_MESSAGE_HRF2 = MQC.MQFMT_RF_HEADER_2;

string mcd_data = MCD_DATA_DEFAULT;
string jms_data = "<jms>jmsText</jms>";
string usr_data = "<usr><targetService>/Testing</targetService><soapAction>http://abc.ttrtrt.com/TestService</soapAction><contentType>text/xml; charset=utf-8</contentType><transportVersion>1</transportVersion><endpointURL></endpointURL></usr>";

int mcd_len = ((mcd_data.Length - 1) / 4) * 4 + 4;
int jms_len = ((jms_data.Length - 1) / 4) * 4 + 4;
int usr_len = ((usr_data.Length - 1) / 4) * 4 + 4;
int msg_len = bMessage.Length;

mcd_data += " ";
mcd_data = mcd_data.Substring(0, mcd_len);
jms_data += " ";
jms_data = jms_data.Substring(0, jms_len);
usr_data += " ";
usr_data = usr_data.Substring(0, usr_len);

mqMsg.Format = FORMAT_MESSAGE_HRF2;
mqMsg.Persistence = (int)MQC.MQPER_PERSISTENT;
mqMsg.WriteString(RFH2_STRUCID_DEFAULT);
mqMsg.WriteLong(RFH2_VERSION_DEFAULT);

mqMsg.WriteLong(RFH2_STRUCLENGTH_DEFAULT + mcd_len + jms_len + usr_len + 12);
mqMsg.WriteLong(RFH2_ENCODING_DEFAULT);
mqMsg.WriteLong(RFH2_CODEDCHARSETID_DEFAULT);
mqMsg.WriteString(RFH2_FORMAT_DEFAULT);
mqMsg.WriteLong(RFH2_FLAGS_DEFAULT);
mqMsg.WriteLong(RFH2_NAMEVALUECCSID_DEFAULT);
mqMsg.WriteLong(mcd_len);
mqMsg.WriteString(mcd_data);
mqMsg.WriteLong(jms_len);
mqMsg.WriteString(jms_data);
mqMsg.WriteLong(usr_len);
mqMsg.WriteString(usr_data);

mqMsg.Write(bMessage);

mqPutMsgOpts.Options = MQC.MQPMO_FAIL_IF_QUIESCING;
mqQueue.Put(mqMsg, mqPutMsgOpts);

Help

Thanks