MQSeries.net :: View topic

Sonal · Posted: Wed May 06, 2009 10:19 pm Post subject: Reason Code 2033.

I sent a message from a sender Queue Manager to the receiver Queue Manager using MQ Explorer. I checked if the message has been sent to the receiver queue or not. Message has been sent. When I don't close the browse window in MQ Explorer and try to retrieve the message from receiver queue using Java code, it shows the following error message:

compile:
run-single:
Connecting to queue manager: QM_RREC
Accessing queue: Q1
...and getting the message back again
An IOException occured whilst writing to the message buffer: java.io.EOFException
BUILD SUCCESSFUL (total time: 1 second)

However, if I close the browse window and then try to run the java code to retrieve sent message in receiver queue, it shows the following error:

compile:
run-single:
Connecting to queue manager: QM_RREC
Accessing queue: Q1
...and getting the message back again
A WebSphere MQ Error occured : Completion Code 2 Reason Code 2033
MQJE001: Completion Code 2, Reason 2033
BUILD SUCCESSFUL (total time: 0 seconds)

I checked if the message is present in the receiver queue or not, I couldn't see the message in receiver queue in MQ Explorer

I read the reason 2033. I think its probably due to in MQGMO (the Options and MatchOptions fields). MQGMO_WAIT option was not specified, or the time interval specified by the WaitInterval field in MQGMO has expired.

I tried to specify the MQGMO_WAIT options but I dunno how to speify it. Could you please help me?

The java code im using is as follows:

package mq;

import com.ibm.mq.*; //Include the WebSphere MQ classes for Java package

public class MQSample {

// define the name of the QueueManager
private static final String qManager = "QM_RREC";
// and define the name of the Queue
private static final String qName = "Q1";

// main method: simply call the runSample() method
public static void main(String args[]) {
new MQSample().runSample();
MQEnvironment.disableTracing ();
MQException.log = null;
}

public void runSample() {

try {
// Create a connection to the QueueManager

System.out.println("Connecting to queue manager: "+qManager);
MQQueueManager qMgr = new MQQueueManager(qManager);

// Set up the options on the queue we wish to open
int openOptions = MQC.MQOO_INPUT_AS_Q_DEF ;
//int openOptions = MQC.MQWI_UNLIMITED ;
//int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT;
// Now specify the queue that we wish to open and the open options
System.out.println("Accessing queue: "+qName);
MQQueue queue = qMgr.accessQueue(qName, openOptions);

// Now get the message back again. First define a WebSphere MQ message
// to receive the data
MQMessage rcvMessage = new MQMessage();

// Specify default get message options
MQGetMessageOptions gmo = new MQGetMessageOptions();

// Get the message off the queue.
System.out.println("...and getting the message back again");
queue.get(rcvMessage, gmo);

// And display the message text...
String msgText = rcvMessage.readUTF();
System.out.println("The message is: " + msgText);

//Close the queue
System.out.println("Closing the queue");
queue.close();

// Disconnect from the QueueManager
System.out.println("Disconnecting from the Queue Manager");
qMgr.disconnect();
System.out.println("Done!");
}
catch (MQException ex) {
System.out.println("A WebSphere MQ Error occured : Completion Code "
+ ex.completionCode + " Reason Code " + ex.reasonCode);
}
catch (java.io.IOException ex) {
System.out.println("An IOException occured whilst writing to the message buffer: "
+ ex);
}
}
}