MQSeries.net :: View topic

metoyokapala · Posted: Wed Jul 14, 2010 6:50 am Post subject:

Good Day all,

I have a code from one of our developers that has COA enabled but i have issue on the Reply Queue where it gets filled and they don't get the reply queue cleaned any syntax that they need to add on their code? Sample code below.

-----
// Write the message to the queue
WriteEvent("IWSMQSeries.Write()", "Begin initializing/writing message to queue", 1, System.Diagnostics.EventLogEntryType.Information, "Application", ".");
mqQueue = mqQMgr.AccessQueue(Queue, MQC.MQOO_OUTPUT);
message = new MQMessage();
//message.WriteString(CustomMessage);
System.Text.ASCIIEncoding encoding = new System.Text.ASCIIEncoding();
message.WriteBytes(CustomMessage);
message.Format = MQC.MQFMT_STRING;
message.PutApplicationType = MQC.MQAT_WINDOWS_NT;
message.Encoding = MQC.MQENC_NATIVE;
message.CharacterSet = MQC.MQCCSI_Q_MGR;
message.CorrelationId = this.GetByteArrayFromString(CorrelationId);
message.ReplyToQueueManagerName = QueueManager;
message.ReplyToQueueName = ReplyQueueName;

// Enable Message Confirm On Arrival (COA) option
if (EnableConfirmOnArrival)
{
pmo.Options |= MQC.MQRO_PASS_CORREL_ID;
////message.MessageType = MQC.MQMT_REPORT;
message.Report = MQC.MQRO_COA;
////message.Feedback = MQC.MQFB_COA;
}

mqQueue.Put(message, pmo);
MessageIdOut = message.MessageId;

WriteEvent("IWSMQSeries.Write()", "End initializing/writing message to queue", 1, System.Diagnostics.EventLogEntryType.Information, "Application", ".");

iResult = 0;

}
catch (MQException e)
{
iResult = -1;
throw e;
}
catch (Exception e)
{
iResult = -1;
throw e;
}
finally
{
// Release resources
if (mqQueue != null)
mqQueue.Close();
if (mqQMgr != null)
mqQMgr.Disconnect();
}

Appreciate the Help.