MQSeries.net :: View topic

crayon_coco · Posted: Tue Mar 15, 2005 10:48 pm Post subject:

I've written a method in C# to browse the message from the queue without removing using MessageID

I realise when the message is found in the Queue i will get the correct message, if the message doesn't exist in the queue i still get the last message in the queue, what could be the problem?

Below in my method

public void Browse(string queueName, byte[] messageID)
{

queue = queueManager.AccessQueue(queueName,MQC.MQOO_BROWSE + MQC.MQOO_INQUIRE + MQC.MQOO_FAIL_IF_QUIESCING + MQC.MQOO_INPUT_SHARED);
MQGetMessageOptions queueGetMessageOptions = new MQGetMessageOptions();
queueGetMessageOptions.Options += MQC.MQGMO_BROWSE_FIRST + MQC.MQMO_MATCH_MSG_ID;
bool done = false;
do
{
try
{
MQMessage queueMessage = new MQMessage();
queueMessage.MessageId = messageID;
queue.Get(queueMessage,queueGetMessageOptions);
this.message = queueMessage.ReadString(queueMessage.MessageLength);
this.isExist = true;
this.isCompleted = true;
queueGetMessageOptions.Options = QGMO_BROWSE_NEXT + MQC.MQGMO_NO_WAIT + MQC.MQGMO_FAIL_IF_QUIESCING + MQC.MQGMO_CONVERT + MQC.MQMO_MATCH_MSG_ID;
}
catch(MQException exp)
{
if(exp.Reason==MQC.MQRC_NO_MSG_AVAILABLE)
{
this.errorMessage = "Message Not Available";
this.isCompleted = true;
done = true;
}
else
{
this.isCompleted = false;
this.errorMessage = exp.Message;
throw new Exception(exp.ToString());
}
}
}while(!done);
}