MQSeries.net :: View topic - need a return code after the message is successfully put

Vishy · Posted: Fri Sep 26, 2003 7:02 am Post subject:

Hi,

I am retrieving an XML message from the table and could successfully put the message on the Q. My probem is I need a return code which returns 0 or 1 if it was successful in putting the Q or not.

This return code is required to update the status of the previously sent message to Y or processed something like that. Is there a way I can get some kind of return code once the message is put on the Q.

here is the code for that. I am reading the hostname, channelname and portno from a table

Please tell me how to modify this method so that I can get a returncode once the message is put.
Thanks in advance

Vishy

public static String sendMessage(String m_msg,String hn, String ch,int pt) throws MQException, IOException{

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

try{
try{

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

System.out.println(" MQEnvironment.HOSTNAME IS " + hn);
System.out.println(" MQEnvironment.CHANNELNAME IS " + ch);
System.out.println(" MQEnvironment.PORTNO IS " + pt);

}catch(Exception ex){

System.out.println("Exception in "+ ex.getMessage());
}

System.out.println("message defined 209" + qManager);

// Create a connection to QManager
//qMgr = new MQQueueManager(MQQueueManager(configParams.getProperty("QMGR")));
qMgr = new MQQueueManager(qManager);

System.out.println("message defined 215");
// 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("SYSTEM.DEFAULT.LOCAL.QUEUE", openOptions);

// Define a simple message
MQMessage mqMsg = new MQMessage();
System.out.println("message defined 223");
//mqMsg.messageType = MQC.MQMT_REQUEST;
mqMsg.format = MQC.MQFMT_STRING;
mqMsg.priority = MQC.MQPRI_PRIORITY_AS_Q_DEF;
mqMsg.expiry = 1200;
mqMsg.writeString(m_msg);
System.out.println("The message string is" + m_msg);
//mqMsg.replyToQueueName = "SYSTEM.DEFAULT.LOCAL.QUEUE";
// Specify the message options
MQPutMessageOptions mqPMO = new MQPutMessageOptions();

// Put the message on the Q
system_default_local_queue.put(mqMsg,mqPMO);

System.out.println( "The request message was put successfully on the queue");

message_Id = mqMsg.messageId;
System.out.println("The message Id is " + mqMsg.messageId);

}catch(MQException e){
System.out.println("MQException: in QManager,PMO " + e.reasonCode + " " + e.getMessage());
}

try{

// Close the Q
system_default_local_queue.close();

// Disconnect from QueueManager
qMgr.disconnect();

}catch (MQException ex) {

System.out.println("A WebSphere MQ error occurred : Completion code " + ex.completionCode + " Reason code " + ex.reasonCode);
System.exit(1);
} finally {
return msgData;
}

}
[/quote]