Click here to Skip to main content
Click here to Skip to main content

IBM Websphere MQ Process Message Immediately with C#

, 21 Sep 2008 CPOL
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

Introduction

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.

Background

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.Options = MQC.MQGMO_FAIL_IF_QUIESCING | MQC.MQGMO_WAIT;
            gmo.WaitInterval = MQC.MQWI_UNLIMITED;
            MQMessage message = new MQMessage();
            //wait for message
            queue.Get(message, gmo);
            queue.Close();

            //release resource.
            mqManager = null;
            queue = null;
            gmo = null;
            System.GC.Collect();

            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)
        {
            Console.WriteLine("==START==");
            String message = null;
            do{
                Console.WriteLine("Waiting...");
                MQMessage mqMessage = MQMessageListener.Listen
				("MANAGER.QUEUE", "LOCAL.QUEUE");
                message = mqMessage.ReadString(mqMessage.MessageLength);
                Console.WriteLine("\tMessage: " + message); 
            }while(message != "BYE");
            Console.WriteLine("==END==");
        }
    }

References

History

  • 21st September, 2008: Initial post

License

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

Share

About the Author

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

Comments and Discussions

 
AnswerMore Information PinmemberVelma W. Johnson4-Jun-14 3:06 
GeneralVery Good Example Fuangwith Pinmembersidiq9-Mar-11 23:29 
GeneralBadly designed MQ code sample PinmemberRogerLacroix22-Sep-08 10:20 
GeneralRe: Badly designed MQ code sample PinmemberMr.Fuangwith S.23-Sep-08 3:02 
GeneralRe: Badly designed MQ code sample PinmemberMario_F27-Sep-08 12:54 
GeneralRe: Badly designed MQ code sample PinmemberRogerLacroix28-Sep-08 7:37 
GeneralRe: Badly designed MQ code sample PinmemberMario_F28-Sep-08 11:11 

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

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

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