MQSeries.net :: View topic

Vishy · Posted: Fri Oct 03, 2003 5:16 am Post subject:

In my code I am specifying the open options on the Q as follows
int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT;

It works fine, if I use SYSTEM.DEFAULT.LOCAL.QUEUE, but once I change it to Queue name specified for development environment, I get the following error ""Completion code 2 Reason code 2045""
Please note that I am using the Q to just put the message on the Q, I am not expecting back any reply.

In the error codes explanation, it says the reason is one of the following
MQRC_OPTION_NOT_VALID_FOR_TYPE
An option that is inappropriate for the object type (for example, MQOO_OUTPUT for an MQOT_PROCESS object).
An option that is unsupported for the queue type (for example, MQOO_INQUIRE for a remote queue that has no local definition).
One or more of the following options:
MQOO_INPUT_AS_Q_DEF

public static int sendMessage(String m_msg,String hn, String ch,int pt,String qManager, String mqQName) throws MQException,Exception{

MQQueueManager qMgr = null;
byte[] message_Id = null;
String msgData = null;
MQQueue system_default_local_queue = null;

try{
MQEnvironment.channel = ch;
MQEnvironment.hostname = hn;
MQEnvironment.port = pt;

// Create a connection to QManager
qMgr = new MQQueueManager(qManager);

// Set up the options on the Q we wish to open
int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT;

// Now specify the Q that we wish to open and the open options
system_default_local_queue = qMgr.accessQueue(mqQName, openOptions);

// Define a simple message
MQMessage mqMsg = new MQMessage();
mqMsg.format = MQC.MQFMT_STRING;
mqMsg.priority = MQC.MQPRI_PRIORITY_AS_Q_DEF;
mqMsg.expiry = 1200;
mqMsg.writeString(m_msg);
MQPutMessageOptions mqPMO = new MQPutMessageOptions();

// Put the message on the Q
system_default_local_queue.put(mqMsg,mqPMO);
rset3 = stmt1.executeQuery ("UPDATE NXT_PSFT_XML_DOCUMENTS SET PROCESSED_FLAG='Y' WHERE PROCESSED_ID =" +m_processed_id);
message_Id = mqMsg.messageId;
System.out.println("The message Id is" + mqMsg.messageId );

// Close the Q
system_default_local_queue.close();

// Disconnect from QueueManager
qMgr.disconnect();
return 0;

} catch (MQException ex) {

System.out.println("A WebSphere MQ error occurred : Completion code " + ex.completionCode + " Reason code " + ex.reasonCode);
return 1;
} catch(SQLException sqle) {
System.out.println("Unable to Access the database");
return 2;
} catch(Exception e) {
System.out.println("Exception caught");
return 3;
}

}

Please help me in resolving this. Thanks in advance

Vishy