MQ: MQException: Completion Code 2, Reason 2033

[Vadim Prudnikov]

Hi. Can you help me with the problem?
I create MQQueueManager, send message and try to receive.
Exception occurs on a message receiving (MQQueue.get).

This is a code parts (i don't show exception catching):

//manager creation
        MQEnvironment.hostname = host;
        MQEnvironment.port = port;
        MQEnvironment.channel = channel;
        MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY,
            MQC.TRANSPORT_MQSERIES); //TCP/IP or server connnection.
        manager = new MQQueueManager(managerName);
 
//method for a message sending
    public void sendMessage(String queueName, String msgText)
        throws MQException, IOException {
 
        int openOptions = MQC.MQOO_OUTPUT | MQC.MQOO_FAIL_IF_QUIESCING;
        MQQueue queue = manager.accessQueue(queueName, openOptions);
        MQMessage message = new MQMessage();
        message.messageType = MQC.MQMT_DATAGRAM;
        message.format=MQC.MQFMT_STRING;
        message.persistence = MQC.MQPER_PERSISTENCE_AS_Q_DEF;
        message.write(msgText.getBytes());
        MQPutMessageOptions pmo = new MQPutMessageOptions();
        //i don't know if the following line is needed.
        //pmo.options = MQC.MQPMO_NEW_CORREL_ID | MQC.MQPMO_NEW_MSG_ID | MQC.MQPMO_FAIL_IF_QUIESCING;
        queue.put(message, pmo);
        queue.close();
    }
 
//method for a message receiving
    public String retrieveMessage(String queueName) throws Exception {
        int openOptions = MQC.MQOO_INPUT_SHARED | MQC.MQOO_FAIL_IF_QUIESCING
            | MQC.MQOO_INQUIRE;
        MQQueue queue = manager.accessQueue(queueName, openOptions);
        MQMessage message = new MQMessage();
        message.messageId = MQC.MQMI_NONE;
        message.correlationId = MQC.MQCI_NONE;
        MQGetMessageOptions gmo = new MQGetMessageOptions();
        //i don't know if the following 3 lines are needed.
        //gmo.options = MQC.MQGMO_WAIT | MQC.MQGMO_CONVERT | MQC.MQGMO_FAIL_IF_QUIESCING;
        //gmo.matchOptions = MQC.MQMO_MATCH_MSG_ID | MQC.MQMO_MATCH_CORREL_ID;
        //gmo.waitInterval = 60000;
        queue.get(message, gmo);
        String msgText = message.readString(message.getMessageLength());
        queue.close();
        return msgText;
    }
 

queue.get(message, gmo); throws an exception.
Help please what parameters are wrong?
Many Thanks.

[Jesus Angeles]

One possible reason for 2033 is timeout.

[Paul Clapham]

"Vad Pr", could you please review the JavaRanch name policy? In particular it says you must use a real name as your display name. You can change your display name here. Thank you for your cooperation.

[Vadim Prudnikov]

with waitInterval = 100000... does not work.
I think the problem is not in timeout.

Any other ideas?

[Paul Clapham]

I googled for that error message and found another answer on a different mailing list. It may or may not apply to your situation.

[Paul Clapham]

And then there's this answer from this very forum 2 1/2 years ago.

[Yogesh Gandhi]

I am also facing the similar problem.

I have written two more 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.
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);