MQSeries.net :: View topic - Put is successful Get fails with 2009 error code.

patkatm · Posted: Tue Jan 20, 2009 7:00 am Post subject:

Hi, everybody. I have peculiar problem. I was able to Connect, Send & recevie the reply from the Q Server. Suddenly I m unable to Get message failure and 2009 error code occurs. If use wiresharke monitoring tool it records the trace between my client and server application I receive TCP re-transmission error. Possible Checksum error etc.

I need to fix this problem please help me. Below copied is the code written in C# executed from Win XP and connecting remotely to a Q Manager which is in different platform.

//*****************************************************//
using System;
using System.Collections;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using IBM.WMQ;

namespace MQClient
{
public class MQClass
{
private MQQueueManager mqQMgr; // MQQueueManager instance
private String queueManger; // Name of queueManager to use
private String GetQName; // Name of Get queue to use
private String SndQName; // Name of Send queue to use

MQQueue mqSndQueue; // MQQueue Send instance
MQQueue mqGetQueue; // MQQueue Get instance

cLogger objLogger; //Trace Logging.
string cClassName;

byte[] PutMsgCorrId; //Store the Correlation ID

private String channelName;
private String connectionName;

public MQClass(string sChannelName)
{
channelName = "SVSV.SVRCONN";
connectionName = "192.100.1.116";
SndQName = "LINKA.REQUEST";
GetQName = "LINKA.REPLY";
queueManger = "SVSVQM";
objLogger = new cLogger();
cClassName = "MQClass";

objLogger.write2Log(cClassName, "Constructor", "*********** APPLICATION START ***********", logTraceLevel.USER);
}

~MQClass()
{
objLogger.write2Log(cClassName, "Destructor", "*********** APPLICATION ENDS ***********", logTraceLevel.USER);
}

/// <summary>
/// Connect to MQ Server.
/// </summary>
/// <param name="sChannelName">Name of the Channel.</param>
/// <param name="sMachineIP">The Server machine's IP.</param>
/// <param name="sQMgrName">Name of the Q Manager.</param>
/// <param name="sQName">Name of the Q.</param>
/// <returns>True or false</returns>
public bool Connect2MQSrvr(string sChannelName, string sMachineIP, string sQMgrName, string sSndQName, string sGetQName)
{
string cMethodName = "Connect2MQSrvr";

bool bResult = true;

objLogger.write2Log(cClassName, cMethodName, "Entered...", logTraceLevel.DEVP);

///
/// Try to create an MQQueueManager instance
///
try
{
//Channel Name
if (sChannelName.Length > 0)
channelName = sChannelName;

//Queue Manager Server IP
if (sMachineIP.Length > 0)
connectionName = sMachineIP;

//Queue Manager name
if (sQMgrName.Length > 0)
queueManger = sQMgrName;

//Send Queue name
if (sSndQName.Length > 0)
SndQName = sSndQName;

//Get Queue name
if (sGetQName.Length > 0)
GetQName = sGetQName;

MQEnvironment.Channel = channelName;
MQEnvironment.Hostname = connectionName;
MQEnvironment.Port = 1414;

Hashtable connectionProperties = new Hashtable();

// Set up the rest of the connection properties, based on the connection type requested
connectionProperties.Add(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES_CLIENT);
connectionProperties.Add(MQC.CCSID_PROPERTY, MQC.CODESET_819);

MQEnvironment.properties = connectionProperties;

objLogger.write2Log(cClassName, cMethodName, channelName + ", " + connectionName + ", 1414.", logTraceLevel.DEVP);

//Open the Queue Manager
mqQMgr = new MQQueueManager(queueManger);

if (mqQMgr == null || !mqQMgr.IsConnected)
{
objLogger.write2Log(cClassName, cMethodName, "Cannot Connect.", logTraceLevel.DEVP);
bResult = false;
}
else
{
objLogger.write2Log(cClassName, cMethodName, "MQ Client connected to the Manager.", logTraceLevel.USER);

///
/// Try to open the queue
///
try
{
// Open / Access the Send Queue

// The named queue may be a model queue, which will result in the
// creation of a temporary dynamic queue, which will be destroyed as
// soon as it is closed. Therefore we must ensure that such a queue
// is not automatically closed and re-opened. We do this by setting
// open options which will avoid the need for closure and re-opening.

mqSndQueue = mqQMgr.AccessQueue(SndQName, MQC.MQOO_FAIL_IF_QUIESCING + MQC.MQOO_OUTPUT, queueManger, "", "");

if (mqSndQueue == null || !mqSndQueue.IsOpen)
{
objLogger.write2Log(cClassName, cMethodName, "Cannot Access Send Queue.", logTraceLevel.DEVP);
bResult = false;
}
else
{
objLogger.write2Log(cClassName, cMethodName, "Accessed Send Queue.", logTraceLevel.DEVP);

////Open / Access the Reply Queue
mqGetQueue = mqQMgr.AccessQueue(GetQName, MQC.MQOO_INPUT_AS_Q_DEF + MQC.MQOO_BROWSE, queueManger, "", "");

if (mqGetQueue == null || !mqGetQueue.IsOpen)
{
objLogger.write2Log(cClassName, cMethodName, "Cannot Access Get Queue.", logTraceLevel.DEVP);
bResult = false;
}
else
objLogger.write2Log(cClassName, cMethodName, "Accessed Get Queue.", logTraceLevel.DEVP);

} //If Open / Access of Send Queue is success
}
catch (MQException mqe)
{
// stop if failed
objLogger.write2Log(cClassName, cMethodName,"Ended with an Error: " + mqe.Message + ", Completion Code: " +
mqe.CompletionCode + ", Reason Code: " + mqe.ReasonCode, logTraceLevel.USER);
bResult = false;
}
} //If QMgr is opened
}
catch (MQException mqe)
{
// stop if failed
objLogger.write2Log(cClassName, cMethodName, "Ended with an Error: " + mqe.Message + ", Completion Code: " +
mqe.CompletionCode + ", Reason Code: " + mqe.ReasonCode, logTraceLevel.USER);
bResult = false;
}

if(!bResult)
DCFrmMQSrvr();

objLogger.write2Log(cClassName, cMethodName, "Exited.... Result:: " + bResult.ToString(), logTraceLevel.USER);
return bResult;
}

/// <summary>
/// Send data to MQ server.
/// </summary>
/// <param name="sData">Data to be placed in the Q.</param>
/// <returns>True or false</returns>
public bool Send2MQServer(string sData)
{
string cMethodName = "Send2MQServer";
String strMessage = "Hello World";
bool bResult = true;
MQMessage mqSndMsg; // MQMessage Send instance
MQPutMessageOptions mqPutMsgOpts; // MQPutMessageOptions instance

mqSndMsg = new MQMessage();

objLogger.write2Log(cClassName, cMethodName, "Entered....", logTraceLevel.USER);

if (mqSndQueue == null || !mqSndQueue.IsOpen || sData.Length < 1 || mqSndMsg == null)
{
objLogger.write2Log(cClassName, cMethodName, "mqSndQueue is not open or no message to transmit or SndMsg not created.",
logTraceLevel.USER);
bResult = false;
}
else
{
///
/// Prepare a message containing the passed data
///

strMessage = sData;

mqSndMsg.ReplyToQueueName = GetQName;
mqSndMsg.ReplyToQueueManagerName = queueManger;
mqSndMsg.CharacterSet = 819;
mqSndMsg.Format = MQC.MQFMT_STRING;
mqSndMsg.MessageType = MQC.MQMT_REQUEST;

//Record the Message sending time
mqSndMsg.PutDateTime = DateTime.Now;

objLogger.write2Log(cClassName, cMethodName, "Put Message Timestamp: " + mqSndMsg.PutDateTime.ToString("yyyyMMdd-HH:MM:ss:mm"),
logTraceLevel.USER);

mqPutMsgOpts = new MQPutMessageOptions();

mqSndMsg.Write(StrToByteArray(strMessage), 0, strMessage.Length);
objLogger.write2Log(cClassName, cMethodName, "Put Msg:: " + strMessage, logTraceLevel.USER);

///
/// Place the message on the queue, using default put message options.
///
try
{
mqSndQueue.Put(mqSndMsg, mqPutMsgOpts);
}
catch (MQException mqe)
{
// report the error
objLogger.write2Log(cClassName, cMethodName, "PutMsg Error: " + mqe.Message + ", Completion Code: " + mqe.CompletionCode +
", Reason: " + mqe.ReasonCode, logTraceLevel.USER);
bResult = false;
}
}

if (!bResult)
DCFrmMQSrvr();

objLogger.write2Log(cClassName, cMethodName, "Exiting...", logTraceLevel.DEVP);

return bResult;
}

/// <summary>
/// Get data From MQ server.
/// </summary>
/// <param name="sData">Data read from the Q.</param>
/// <returns>True / False</returns>
public string GetFrmMQServer()
{
string cMethodName = "GetFrmMQServer";
MQMessage mqGetMsg;

MQGetMessageOptions mqGetMsgOpts;
string sData = "";
byte[] bData;
bool bErrFlg = false;

///
/// Try to open the queue
///
try
{
objLogger.write2Log(cClassName, cMethodName, "Entered...", logTraceLevel.DEVP);

//int iOpenOptions = MQC.MQOO_INPUT_AS_Q_DEF + MQC.MQOO_BROWSE;

mqGetMsg.CharacterSet = 437; //Default value is CharacterSet 819 (iso-8859-1/latin/ibm819), 437 - ibm437 / PC Original.
mqGetMsg.Format = MQC.MQFMT_STRING;

mqGetMsgOpts = new MQGetMessageOptions(); // MQGetMessageOptions instance

//Message type - REQUEST type (instructed by Amadeus)
mqGetMsg.MessageType = MQC.MQMT_REQUEST;

mqGetMsgOpts.Version = MQC.MQGMO_VERSION_1;

//Maximum time to wait (milliseconds) for the reply message
//mqGetMsgOpts.WaitInterval = 1000*40;

bool bContinue = true;

//while (bContinue)
//{
bErrFlg = false;
bContinue = true;

try
{
mqGetQueue.Get(mqGetMsg, mqGetMsgOpts);

objLogger.write2Log(cClassName, cMethodName, "CorrelationID:: " + ByteArrayToStr(mqGetMsg.CorrelationId) + " == " +
ByteArrayToStr(PutMsgCorrId), logTraceLevel.DEVP);

if (mqGetMsg.MessageLength != 0)// && mqGetMsg.CorrelationId == PutMsgCorrId)
{
// Show the text of the received message.
objLogger.write2Log(cClassName, cMethodName, "Message of length " + mqGetMsg.MessageLength.ToString() +
" bytes received.", logTraceLevel.DEVP);

bData = mqGetMsg.ReadBytes(mqGetMsg.MessageLength);

objLogger.write2Log(cClassName, cMethodName, "Data received:: " + bData.ToString(), logTraceLevel.DEVP);
sData = ByteArrayToStr(bData);
bContinue = false;
bErrFlg = false;
}
//else
// mqGetMsgOpts.Options = MQC.MQGMO_BROWSE_NEXT;
}
catch (MQException mqe)
{
bContinue = false;

// report reason, if any
if (mqe.Reason == MQC.MQRC_NO_MSG_AVAILABLE)
{
// special report for normal end
objLogger.write2Log(cClassName, cMethodName, "No more messages retrieve.", logTraceLevel.USER);
}
// general report for other reasons
objLogger.write2Log(cClassName, cMethodName, "Ended with Error:: " + mqe.Message + ", Completion Code: " +
mqe.CompletionCode + ", Reason code: " + mqe.ReasonCode, logTraceLevel.USER);
sData = "";
} //End of Catch block
//} //End of While loop
} //End of Else-If GetQ is not open / accessible.

//if (mqGetQueue.OpenStatus)
// mqGetQueue.Close();
}
catch (MQException mqe)
{
// report the error
objLogger.write2Log(cClassName, cMethodName, "Ended with Error:: " + mqe.Message + ", Completion Code: " +
mqe.CompletionCode + ", Reason code: " + mqe.ReasonCode, logTraceLevel.USER);
bErrFlg = true;
sData = "";
}

if(bErrFlg)
DCFrmMQSrvr();

return sData;
}

/// <summary>
/// DisConnect FRM MQ Server.
/// </summary>
/// <returns></returns>
public bool DCFrmMQSrvr()
{
bool bResult = true;
string cMethodName = "DCFrmMQSrvr";

try
{
objLogger.write2Log(cClassName, cMethodName, "Entering...", logTraceLevel.DEVP);

if (mqSndQueue != null && mqSndQueue.IsOpen)
{
objLogger.write2Log(cClassName, cMethodName, "Closing Send Queue.", logTraceLevel.DEVP);
//Close the Queue
mqSndQueue.Close();
}

if (mqGetQueue != null && mqGetQueue.IsOpen)
{
objLogger.write2Log(cClassName, cMethodName, "Closing Get Queue.", logTraceLevel.DEVP);
//Close the Queue
mqGetQueue.Close();
}

if (mqQMgr != null && mqQMgr.IsConnected)
{
objLogger.write2Log(cClassName, cMethodName, "Disconnecting Manager.", logTraceLevel.DEVP);
//Close the Queue Manager
mqQMgr.Disconnect();
}
}
catch (MQException mqe)
{
objLogger.write2Log(cClassName, cMethodName, "MQ error: " + mqe.Message + ", Completion code: " +
mqe.CompletionCode + ", Reason code: " + mqe.ReasonCode, logTraceLevel.USER);
bResult = false;
}
objLogger.write2Log(cClassName, cMethodName, "Exiting....", logTraceLevel.DEVP);
return bResult;
}

public static byte[] StrToByteArray(string str)
{
System.Text.ASCIIEncoding encoding = new System.Text.ASCIIEncoding();
return encoding.GetBytes(str);
}

public static String ByteArrayToStr(byte[] bstr)
{
System.Text.ASCIIEncoding encoding = new System.Text.ASCIIEncoding();
return encoding.GetString(bstr, 0, bstr.Length);
}
}
}

//*****************************************************//