MQSeries.net :: View topic

robertjenkin · Posted: Fri Nov 12, 2004 10:55 am Post subject:

Hello all..

I have a simple c# program to get messages from queue. I need to get messages from MQ within transaction so I am executing Begin and Commit methods to control the transaction. When ever I execute Begin I get an 2018 error. Without the Begin/Commit statements all works. Any ideas or hints would be greatly appreicated.

Following is the class code I am currently using.

public class MQInterface
{
private MQQueueManager mqQMgr;
private MQQueue mqQueue;
private MQGetMessageOptions mqGetMsgOpts;
private MQMessage mqMsg;
private bool bConnected = false;
private bool bTransaction = false;

public MQInterface() {}

public bool Connect(string mqQueueMgr, string mqQueueName, string mqChannel) {
// determine how to connect
string[] parts;
char[] separator = {'/'};
string channelname = "";
string transporttype = "";
string connectionname = "";

// connect to queue manager
try {
if (mqChannel.Length > 0) {
parts = mqChannel.Split(separator);
if (parts.Length>0) channelname = parts[0];
if (parts.Length>1) transporttype = parts[1];
if (parts.Length>2) connectionname = parts[2];
mqQMgr = new MQQueueManager(mqQueueMgr,channelname,connectionname);
} else {
if (mqQueueMgr.Length>0) {
mqQMgr = new MQQueueManager(mqQueueMgr);
} else {
mqQMgr = new MQQueueManager();
}
}
} catch (MQException ex) {
bConnected = false;
throw ex;
}

try {
mqQueue = mqQMgr.AccessQueue(mqQueueName,MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_FAIL_IF_QUIESCING);
} catch (MQException ex) {
bConnected = false;
throw ex;
}

mqGetMsgOpts = new MQGetMessageOptions();
mqGetMsgOpts.Options = MQC.MQGMO_WAIT;
mqGetMsgOpts.WaitInterval = 15 * 1000;
mqGetMsgOpts.MatchOptions = MQC.MQMO_NONE;
bConnected = true;
return (bConnected);
}

public void Disconnect() {
mqQueue.Close();
mqQMgr.Disconnect();
bTransaction = false;
bConnected = false;
}

public bool Begin() {
try {
mqQMgr.Begin();
bTransaction = true;
return (true);
} catch (MQException ex) {
throw ex;
}
}

public bool Commit() {
try {
mqQMgr.Commit();
bTransaction = false;
return (true);
} catch (MQException ex) {
throw ex;
}
}

public bool RollBack() {
try {
mqQMgr.Backout();
bTransaction = false;
return (true);
} catch (MQException ex) {
throw ex;
}
}

public bool Process(ref string sMessage) {
if (!bConnected) {
sMessage = "";
return (false);
}
try {
mqMsg = new MQMessage();
mqMsg.Format=MQC.MQFMT_STRING;
try {
mqQueue.Get(mqMsg, mqGetMsgOpts);
sMessage = mqMsg.ReadString(mqMsg.MessageLength);
} catch(MQException e) {
if (e.Reason == MQC.MQRC_NO_MSG_AVAILABLE) {
sMessage = "";
return (false);
} else {
throw e;
}
}
} catch(MQException e) {
throw e;
}
return (true);
}
}