Sample java client for WebSphere MQ-Consumer and producer

Assuming that you have already installed IBM Websphere MQ version 7.5 or above in your machine, this tutorial will help you create simple consumer and producer app that uses Websphere MQ. The language used is java.

To create a Queue manager in windows, open the command prompt as the administrator and type the following command.

crtmqm QMGR1

This would create a queue manager with the name QMGR1.

Now to display a list of queue managers that exist on the machine and their status:

dspmq

You can start the queue manager thus created:

strmqm QMGR1

To End (stop) a queue manager:

endmqm QMGR1

To start the interactive console for MQSC commands (which enable you to perform administration tasks):

runmqsc QMGR1

To create a queue run the interactive console for MQSC commands then:

define qlocal(MQ.REQUEST)

The above command will create a local queue named MQ.REQUEST.

Once you have created a queue manager and a queue and started the queue manager, without further ado let’s see how to create the Producer:

import com.ibm.mq.MQException;
import com.ibm.mq.constants.CMQC;
import com.ibm.mq.MQMessage;
import com.ibm.mq.MQPutMessageOptions;
import com.ibm.mq.MQQueue;
import com.ibm.mq.MQQueueManager;
import java.io.IOException;

/**
 * This class is an example of JMS Client. Using sendMsg() method you can send a message to the IBM MQ
 *
 * @author Riyafa Abdul Hameed
 * @version 1.0
 */
public class SimpleJMSProducer
{
    public void sendMsg(String msg)
    {
        MQQueueManager queueManager = null;
        MQMessage mqMessage = null;
        MQPutMessageOptions myPMO = null;

        try
        {

            // creating queue manager
            queueManager = new MQQueueManager("QMGR1");

            // creating queue`

            MQQueue queue = queueManager.accessQueue("MQ.REQUEST", CMQC.MQOO_OUTPUT);

            // configuring message encoding, character set, and format

            mqMessage = new MQMessage();
            mqMessage.encoding = new Integer("546");
            mqMessage.characterSet = new Integer("1208");
            mqMessage.format = "MQSTR";

            // sending message

            mqMessage.writeString(msg);
            myPMO = new MQPutMessageOptions();
            queue.put(mqMessage, myPMO);
            
            // Closing Queue after putting message
            queue.close();

        } catch (MQException | NumberFormatException | IOException je)
        {
            je.printStackTrace(System.err);
        } finally
        {
            if (queueManager != null) try
            {
                // Disconnecting queue manager
                queueManager.disconnect();
            } catch (MQException ex) {
                ex.printStackTrace(System.err);
            } 
        }
    }

    public static void main(String[] args)
    {
        new SimpleJMSProducer().sendMsg("Hello world!!!");
    }
}

In order to run this example you need com.ibm.mq.jar and com.ibm.mq.jmqi.jar. You can find these jar files if you go to your websphere location and to java\lib folder. In windows:

C:\Program Files (x86)\IBM\WebSphere MQ\java\lib

You can replace QMGR1 and MQ.REQUEST with the name of the queue manager and queue respectively as you would have created.

Similarly the code for the Consumer:

import com.ibm.mq.MQException;
import com.ibm.mq.constants.CMQC;
import com.ibm.mq.MQMessage;
import com.ibm.mq.MQQueue;
import com.ibm.mq.MQQueueManager;
import java.io.IOException;

/**
 * This class is an example of JMS Client. Using receive() method you can receive a message to the IBM MQ if it exists
 *
 * @author Riyafa Abdul Hameed
 * @version 1.0
 */

public class SimpleJMSConsumer
{
    public String receiveMsg()
    {
        MQQueueManager queueManager = null;
        MQMessage mqMessage = null;

        try
        {

            // creating queue manager
            queueManager = new MQQueueManager("QMGR1");

            // creating queue`

            MQQueue queue = queueManager.accessQueue("MQ.REQUEST", CMQC.MQOO_INPUT_SHARED);

            // configuring message encoding, character set, and format

            mqMessage = new MQMessage();
            
            // receiving message

            queue.get(mqMessage);
            // Closing Queue after putting message
            queue.close();
           return mqMessage.readStringOfByteLength(mqMessage.getMessageLength());
            

        } catch (MQException | IOException je)
        {
            je.printStackTrace(System.err);
        } finally
        {
            if (queueManager != null) try
            {
                // Disconnecting queue manager
                queueManager.disconnect();
            } catch (Exception e)
            {
                e.printStackTrace(System.err);
            }
        }
        return "";
    }

    public static void main(String[] args)
    {
        System.out.println(new SimpleJMSConsumer().receiveMsg());
    }
}

 

 

You can find the code on github:

https://github.com/riyafa/websphere/tree/master/src/riyafa