Click here to Skip to main content
13,042,630 members (85,906 online)
Click here to Skip to main content
Add your own
alternative version


17 bookmarked
Posted 21 Sep 2008

IBM Websphere MQ Process Message Immediately with C#

, 21 Sep 2008
Rate this:
Please Sign up or sign in to vote.
IBM Websphere MQ process message immediately with C#
Sample Image - maximum width is 600 pixels


In IBM Websphere MQ applications, usually we need to process a suitable message to arrive into the queue immediately. In this case, the Polling method is not a good solution; waiting for the message or event-driven are better solutions.

IBM Websphere MQ provides Triggering for process messages arriving on queues. Actually, MQ's Triggering is very fussy. You must create the initial queue, process, etc. It is important that you must run the 'runmqtrm' command for monitoring MQ's Triggering on the queue that you want.

I present a simple solution for this case. If you what to know when the message is arriving in queues, why don't you wait for the message.


Before it is possible to use the WebSphere MQ object's properties, methods, or events, a reference must be created to the object. The technique to add a WebSphere MQ reference is by adding amqmdnet.dll as a reference. This Dynamic Link Library (DLL) is typically located at: C:\Program Files\IBM\WebSphere MQ\bin\amqmdnet.dll and using IBM.WMQ;

Using the Code

The MQMessageListener class provides the Listen method to wait for a suitable message that arrives on the queue manager qmName and queue queueName.

In the MQMessageListener class, MQQueueManager set open options are MQOO_INPUT_AS_Q_DEF and MQOO_FAIL_IF_QUIESCING for connecting to Websphere MQ for getting a message using queue-define and fails if that queue is in quiescing mode. Then MQGetMessageOptions set are MQGMO_FAIL_IF_QUIESCING and MQGMO_WAIT for MQGMO_WAIT. This option is used with the WaitInterval method when you set WaitInterval is MQWI_UNLIMITED application will wait for the message to arrive in the queue at queue.Get(message, gmo). When the message is arriving on the queue, the application will run to return the message.

public class MQMessageListener
        public static MQMessage Listen(string qmName, string queueName)
            /** MQOO_INPUT_AS_Q_DEF -- open queue to get message 
	    *  using queue-define default.
             *  MQOO_FAIL_IF_QUIESCING -- access fail if queue manager is quiescing. **/
            int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_FAIL_IF_QUIESCING;
            MQQueueManager mqManager = new MQQueueManager(qmName);
            MQQueue queue = mqManager.AccessQueue(queueName,openOptions);

            /** MQGMO_FAIL_IF_QUIESCING -- 
	    *  get message fail if queue manager is quiescing.
             *  MQGMO_WAIT -- waits for suitable message to arrive.
             *  MQWI_UNLIMITED -- unlimited wait interval. **/
            MQGetMessageOptions gmo = new MQGetMessageOptions();
            gmo.WaitInterval = MQC.MQWI_UNLIMITED;
            MQMessage message = new MQMessage();
            //wait for message
            queue.Get(message, gmo);

            //release resource.
            mqManager = null;
            queue = null;
            gmo = null;

            return message;

The Program class is the default class when you create a project with Visual Studio. This class contains the Main method and the application starts here.

class Program
       static void Main(string[] args)
           String message = null;
               MQMessage mqMessage = MQMessageListener.Listen
               ("MANAGER.QUEUE", "LOCAL.QUEUE");
               message = mqMessage.ReadString(mqMessage.MessageLength);
               Console.WriteLine("\tMessage: " + message);
           }while(message != "BYE");



  • 21st September, 2008: Initial post


This article, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)


About the Author

Mr.Fuangwith S.
Software Developer (Senior)
Thailand Thailand
No Biography provided

You may also be interested in...


Comments and Discussions

AnswerMore Information Pin
Velma W. Johnson4-Jun-14 2:06
memberVelma W. Johnson4-Jun-14 2:06 
GeneralVery Good Example Fuangwith Pin
sidiq9-Mar-11 22:29
membersidiq9-Mar-11 22:29 
GeneralBadly designed MQ code sample Pin
RogerLacroix22-Sep-08 9:20
memberRogerLacroix22-Sep-08 9:20 
GeneralRe: Badly designed MQ code sample Pin
Mr.Fuangwith S.23-Sep-08 2:02
memberMr.Fuangwith S.23-Sep-08 2:02 
GeneralRe: Badly designed MQ code sample Pin
Mario_F27-Sep-08 11:54
memberMario_F27-Sep-08 11:54 
GeneralRe: Badly designed MQ code sample Pin
RogerLacroix28-Sep-08 6:37
memberRogerLacroix28-Sep-08 6:37 
GeneralRe: Badly designed MQ code sample Pin
Mario_F28-Sep-08 10:11
memberMario_F28-Sep-08 10:11 

General General    News News    Suggestion Suggestion    Question Question    Bug Bug    Answer Answer    Joke Joke    Praise Praise    Rant Rant    Admin Admin   

Use Ctrl+Left/Right to switch messages, Ctrl+Up/Down to switch threads, Ctrl+Shift+Left/Right to switch pages.

Permalink | Advertise | Privacy | Terms of Use | Mobile
Web02 | 2.8.170713.1 | Last Updated 21 Sep 2008
Article Copyright 2008 by Mr.Fuangwith S.
Everything else Copyright © CodeProject, 1999-2017
Layout: fixed | fluid