MQSeries.net :: View topic

rchiroldes · Posted: Wed Jun 18, 2008 9:56 am Post subject:

Hi! Dudes,

I have a C# application using AMQMDNET.DLL API for putting messages in remote queues defined in one host/server. My code looks like this:

public override int SendDataToHost(string msg)
{
MQQueueManager mqQMgr; // MQQueueManager instance
MQQueue mqQueue1; // MQQueue instance
MQMessage mqMsg; // MQMessage instance
MQPutMessageOptions mqPutMsgOpts; // MQPutMessageOptions instance

IBM.WMQ.MQEnvironment.Channel = this.mqsconfig.MQSCHANNELNAME;
IBM.WMQ.MQEnvironment.Hostname = this.mqsconfig.MQSCONNECTIONNAME;
IBM.WMQ.MQEnvironment.Port = this.mqsconfig.MQSTCPPORT;

try
{
//mqQMgr = new MQQueueManager(this.mqsconfig.MQSQMANAGER,this.mqsconfig.MQSCHANNELNAME,this.mqsconfig.MQSCONNECTIONNAME);
mqQMgr = new MQQueueManager(this.mqsconfig.MQSQMANAGER,MQC.MQCNO_HANDLE_SHARE_NO_BLOCK,this.mqsconfig.MQSCHANNELNAME,this.mqsconfig.MQSCONNECTIONNAME);
}
catch (MQException mqe)
{
return (mqe.Reason > 0) ? mqe.Reason * -1 : mqe.Reason;
}

if (mqQMgr == null)
return -1;

try
{
mqQueue1 = mqQMgr.AccessQueue(this.mqsconfig.MQSOUTPUTQNAME,
MQC.MQOO_OUTPUT // open queue for output
+ MQC.MQOO_FAIL_IF_QUIESCING ); // but not if MQM stopping
}
catch (MQException mqe)
{
// stop if failed
//MessageBox.Show( "Manager::AccessQueue ended with " + mqe.Message + " MQ ACCESS DENIE Reason Code " + mqe.Reason.ToString());

return (mqe.Reason > 0) ? mqe.Reason * -1 : mqe.Reason;
}

mqMsg = new MQMessage();
mqMsg.WriteString(msg);
mqMsg.Format = MQC.MQFMT_STRING;
mqPutMsgOpts = new MQPutMessageOptions();
mqMsg.Expiry = 600;

try
{
mqQueue1.Put(mqMsg, mqPutMsgOpts );
}
catch (MQException mqe)
{
// report the error
//MessageBox.Show( "MQQueue::Put ended with " + mqe.Message );

return (mqe.Reason > 0) ? mqe.Reason * -1 : mqe.Reason;
//return -2;
}

this.MQSINTERNALKEY = mqMsg.MessageId;

mqQueue1.Close();
return msg.Length;

}

do you know if I'm using the correct way for putting messages??

Thanks

PS: this application is used for multiple clients at the same time and all of them are putting message in the same queue defined in another server.

PSS: in the server where this C# application is running we only have installed the MQ Client.