MQSeries.net :: View topic - Posting a message to MQSeries with a Message Id

rivast_2001 · Posted: Mon Apr 18, 2005 7:25 am Post subject:

I am creating a .NET application where I am trying to write and read a message to an iSeries MQSeries queue and this is done without any issues. At this moment I am at the point that I need to assign a Message Id to the message. For this I am following the method signature specifications where the message need to be a byte array. I can write and read from the queue with not issues. My questions is when I am trying to see the message from the iSeries Queue Manager interface programs, specially option "Display MQ Message Description", I am not able to see the message Id I am writing nor the RPG program that is reading the message from the queue. Which format should I be using to write this byte array from the .NET application? The description of my environment is the following,

- .NET framework 1.1
- Visual Studio 2003
- iSeries Web Sphere MQ
- Web Sphere MQ Series Developer Toolkit CSD 07
- WebSphere MQ classes for Microsoft .NET - ma7p.msi - amqmdnet.dll

I have tested the application writing to MQ in the iSeries using the following segment of code. I have also tested the following encoding types and none of them allows me to see the message id on the iSeries interface.

- _putMessage.MessageId = System.Text.Encoding.ASCII.GetBytes(inMessageId);
- _putMessage.MessageId = System.Text.Encoding.BigEndianUnicode.GetBytes(inMessageId);
- _putMessage.MessageId = System.Text.Encoding.Default.GetBytes(inMessageId);
- _putMessage.MessageId = System.Text.Encoding.Unicode.GetBytes(inMessageId);
- _putMessage.MessageId = System.Text.Encoding.UTF7.GetBytes(inMessageId);
- _putMessage.MessageId = System.Text.Encoding.UTF8.GetBytes(inMessageId);

Sample of the method used to write to MQ Series queue.

public byte[] PutMessageIntoQueue(string inQueueName,
string inMessage, EnumMessageFormat inMessageFormat, int inPriority, string inMessageId,
int inSecondsToExpire, bool inCloseQueue)
{
byte[] outValue;

IBM.WMQ.MQQueue backupQueue = null;;
string backupQueueName = string.Empty;

try
{
if (inMessage.Trim().Length == 0)
throw new Exception(CONST_INVALID_MESSAGE);

//checking if connection with _queue manager is active
CheckQueueManagerConnection();

int openOptions = MQC.MQOO_OUTPUT;

if (
(_queue == null)
|| (_queueName.Trim().ToUpper() != inQueueName.Trim().ToUpper())
|| (_queue.OpenOptions != openOptions)
)
{
if (_queue != null)
{
backupQueue = _queue;
backupQueueName = _queueName;
}

_queue = _qManager.AccessQueue(inQueueName, openOptions);
_queueName = inQueueName;
}

_putMessage = new MQMessage();
_putMessageOptions = new MQPutMessageOptions();

//specifying ibm037 character set identifier
_putMessage.CharacterSet = 37;

//specifying message identifier
if ( (inMessageId != null) && (inMessageId.Length) > 0)
{
_putMessage.MessageId = System.Text.Encoding.UTF8.GetBytes(inMessageId);
_putMessage.CorrelationId = MQC.MQCI_NONE;
}

//specifying the number of second for the message to expire
//values is specified in tenth of a second
if (inSecondsToExpire > 0)
_putMessage.Expiry = inSecondsToExpire * 10;

//setting priority of the message
if (inPriority > 0) _putMessage.Priority = inPriority;

//setting the nature of the message to the receiver
_putMessage.Format = MQC.MQFMT_STRING;

switch(inMessageFormat)
{
case EnumMessageFormat.UTFFormat:
{
_putMessage.WriteUTF(inMessage);
break;
}
default:
{
_putMessage.WriteString(inMessage);
break;
}
}
//putting the message into the _queue
_queue.Put(_putMessage, _putMessageOptions);

//returning the messageId assigned by the _queue manager
outValue = _putMessage.MessageId;

//closing the _queue
if (inCloseQueue)
{
_qManager.Commit();
_queue.Close();
_queue = null;
}

if (backupQueue != null)
{
if (!inCloseQueue) _queue.Close();
_queue = backupQueue;
_queueName = backupQueueName;
}

}
catch(Exception exc)
{
throw new Exception(
string.Format("Error {0} when putting messageinto queue \"{1}\".", exc.Message, inQueueName), exc);
}
return outValue;
}

--This is a sample of the information I am seeing on the iSeries

Display MQ Message Description

Queue Manager Name . : PARTNERVALQM
Queue name . . . . . : PRAS.OUTPUT.LOCAL.QUEUE
Report options . . . : NONE
Message type . . . . : DATAGRAM
Feedback code . . . : NONE
Data encoding . . . : REVERSE REVERSE IEEE_REVERSED
Coded character set
identifier . . . . : 37
Format name . . . . : MQSTR
Message priority . . : 0
Message persistence : NOT PERSISTENT
Message ID . . . . . : . . . . . . . . . . . . . . . . . . . . . . . .
Message ID
(Hexadecimal) . . : 563139313332343837343030303530343131303132373536
Correlation ID . . . : . . . . . . . . . . . . . . . . . . . . . . . .
Correlation ID
(Hexadecimal) . . : 000000000000000000000000000000000000000000000000
Backout counter . . : 0
Name of reply queue :

Display MQ Message Description

Hope someone have an answer for me on this. Thanks a lot.