Problem reading mesage from MQ - 2033

[Yogesh Gandhi]

I am facing a problem when reading from a MQ queue.

I have written two functions:

    public String readRequestMQMessage(String xmlRequestID) //throws MQException, Exception
    {
        return readMQMessage(xmlRequestID, outputRequestQueueName);
    }

    public String readEnquiryMQMessage(String xmlRequestID) //throws MQException, Exception
    {
        return readMQMessage(xmlRequestID, outputEnquiryQueueName);
    }

Only difference in the two functions is that queueName is being changed (which is being passed as a parameter)
.
But I get a message 2033 when reading from Enquiry Queue, while the same code works perfectly fine in case of Request Queue.

Can anyone give me a clue, what could be the possible reason for such a behavior.


The function readMQMessage uses the following options:

        int intoptionForOutputQueue =
            MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT;

            getMsgOptionsMq = new MQGetMessageOptions();
            getMsgOptionsMq.options = MQC.MQGMO_SYNCPOINT; //8195;
            getMsgOptionsMq.matchOptions =
                    MQC.MQMO_MATCH_CORREL_ID;

            MQEnvironment.hostname = MQHostname;
            MQEnvironment.channel = channelName;
            MQEnvironment.port = Integer.parseInt(MQPortname);
            MQEnvironment.properties.put("transport", "MQSeries Client");

            outMQueue =
                    qManager.accessQueue(outputQueueName, intoptionForOutputQueue,
                                         null, null, null);

            MQMessage retrievedMsg = new MQMessage();

            retrievedMsg.correlationId = correlationByte;

            outMQueue.get(retrievedMsg, getMsgOptionsMq);

[Yogesh Gandhi]

At last I had to use browseEnquiryMessage method to read all the messages present in the queue. (That worked).
This worked for me, I don't know the reason, but I was able to get rid of my problem.

    /*
     * This function iterates over all the present messages
     * in the Enquiry queue, creates an arrayList of all the messages
     * and returns the arrayList.
     * Also, this function will delete the message after
     * it reads the message from the queue.
     */
    public ArrayList<String> browseEnquiryMessage() {
        ArrayList<String> messages = new ArrayList<String>();
        MQQueueManager qMgr = null;
        MQQueue queue = null;
        try {
            // Create a connection to the QueueManager
            debug("RTGS : browseEnquiryMessage : Connecting to queue manager: " + QManagerName);
            qMgr = new MQQueueManager(QManagerName);
            // Set up the options on the queue we wish to open
            int openOptions = MQC.MQOO_BROWSE | MQC.MQOO_INPUT_SHARED;
            // Now specify the queue that we wish to open and the open options
            debug("RTGS : browseEnquiryMessage :  Accessing queue: " + outputEnquiryQueueName);
            queue = qMgr.accessQueue(outputEnquiryQueueName, openOptions, null, null, null);
            MQGetMessageOptions getMessageOptions = new MQGetMessageOptions();
            getMessageOptions.options = MQC.MQGMO_BROWSE_FIRST | MQC.MQGMO_WAIT;
            getMessageOptions.waitInterval = 1000;
            // Get the message off the queue.
            int iCount = 0;
            while (true)
            {
                iCount++;
                MQMessage rcvMessage = new MQMessage();
                try
                {
                    // Again set these properties as another BRE thread may have
                    // overwritten these values by the time control reaches this point.
                    MQEnvironment.hostname = MQHostname;
                    MQEnvironment.channel = channelName;
                    MQEnvironment.port = Integer.parseInt(MQPortname);
                    MQEnvironment.CCSID = 819;
                    MQEnvironment.properties.put("transport", "MQSeries Client");
                    debug("RTGS : browseEnquiryMessage : Reading message no. " + iCount);
                    queue.get(rcvMessage, getMessageOptions);


                    getMessageOptions.options = MQC.MQGMO_MSG_UNDER_CURSOR;
                    MQEnvironment.hostname = MQHostname;
                    MQEnvironment.channel = channelName;
                    MQEnvironment.port = Integer.parseInt(MQPortname);
                    MQEnvironment.CCSID = 819;
                    MQEnvironment.properties.put("transport", "MQSeries Client");
                    // You can remove from the queue a message you have already
                    // browsed provided you have opened the queue for removing
                    // messages as well as for browsing. (You must specify one of the
                    // MQOO_INPUT_* options, as well as the MQOO_BROWSE option, on
                    // your MQOPEN call)
                    // To remove the message call MGET again, but in the
                    // Options field of the MQMGMO structure, specify  MQGMO_MSG_UNDER_CURSOR
                    // In this case, the MQGET call ignores the MsgId, correlation id,
                    // and group id fields of the MQMD structure.

                    // For more details refer page 151 of MQ Programming guide in java.
                    queue.get(rcvMessage, getMessageOptions);
                }
                catch(MQException mq)
                {
                    int MQRC_NO_MSG_AVAILABLE = 2033;
                    if (mq.reasonCode == MQRC_NO_MSG_AVAILABLE)
                    {
                        debug("RTGS : browseEnquiryMessage : MQEnvironment.hostname = " + MQEnvironment.hostname);
                        debug("RTGS : browseEnquiryMessage : MQEnvironment.channel = " + MQEnvironment.channel);
                        debug("RTGS : browseEnquiryMessage : MQEnvironment.port = " + MQEnvironment.port);
                        debug("No more messages on the specified queue : " + outputEnquiryQueueName);
                        break;
                    }
                    else
                    {
                        error("RTGS : browseEnquiryMessage : MQ Completion Code " + mq.completionCode);
                        error("RTGS : browseEnquiryMessage : MQ Reason Code " + mq.reasonCode);
                        error("RTGS : browseEnquiryMessage : MQ Get Message " + mq.getMessage());
                    }
                }
                catch(Throwable t)
                {
                    error(t.getMessage(), t);
                    break;
                }
                byte[] b = new byte[rcvMessage.getMessageLength()];
                rcvMessage.readFully(b);
                String msgText = new String(b);
                if (msgText.trim().equals("")) {
                    break;
                }
                messages.add(msgText);
                getMessageOptions.options = MQC.MQGMO_BROWSE_NEXT;
            }
            debug("RTGS : browseEnquiryMessage : Size of ArrayList to be returned = " + messages.size());
            return messages;
        } catch (MQException ex) {
            int MQRC_NO_MSG_AVAILABLE = 2033;
            if (ex.reasonCode == MQRC_NO_MSG_AVAILABLE) {
                debug("RTGS : browseEnquiryMessage :No more messages ");
            } else {
                debug("RTGS : browseEnquiryMessage :A WebSphere MQ Error occured : Completion Code " + ex.completionCode + " Reason Code " + ex.reasonCode);
            }
        } catch (java.io.IOException ex) {
            debug("RTGS : browseEnquiryMessage :An IOException occured while reading to the message buffer: " + ex);
        } finally {
            try {
                debug("RTGS : browseEnquiryMessage :Closing the queue");
                queue.close();
                debug("RTGS : browseEnquiryMessage :Disconnecting from the Queue Manager");
                qMgr.disconnect();
                debug("RTGS : browseEnquiryMessage :Done!");
            } catch (Exception e) {
                debug("RTGS : browseEnquiryMessage :Error in finally!");
            }
        }
        debug("RTGS : browseEnquiryMessage : Size of ArrayList to be returned = " + messages.size());
        return messages;
    }