| Code:
|
/**
* Send Message to WMQ
*/
public void processRequest() {
String sRequestManager = null;
String sRequestQueue = null;
for (PropertiesClass oList : arList) {
sRequestManager = oList.getRequestQManager();
sRequestQueue = oList.getRequestQueueName();
}
try {
// Create a connection to the queue manager
requestQMgr = new MQQueueManager(sRequestManager);
// Set options
int iOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT;
// Open queue and set options
requestQueue = requestQMgr.accessQueue(sRequestQueue, iOptions,
null, null, null);
// Build Message
MQMessage send_msg = new MQMessage();
// Get the message from the jTextArea
send_msg.writeUTF(textAreaMessage.getText().trim());
// Set the options
MQPutMessageOptions pmo = new MQPutMessageOptions();
// put the message on the queue
requestQueue.put(send_msg, pmo);
// Close the Queue
requestQueue.close();
// Disconnect from the queue manager
requestQMgr.disconnect();
setFonts(false, "Message has been placed on the Queue "
+ sRequestQueue + " With Message of: "
+ textAreaMessage.getText());
} catch (MQException ex) {
// MQ Error
System.out.println("An MQSeries error occurred : Completion code "
+ ex.completionCode + " Reason code " + ex.reasonCode);
setFonts(true, "An MQException error: Completion code "
+ ex.completionCode + " Reason code " + ex.reasonCode);
}
// Buffer Error?
catch (java.io.IOException ex) {
System.out
.println("An error occurred while writing to the message buffer: "
+ ex);
setFonts(true,
"An error occurred while writing to the message buffer: "
+ ex);
}
}
|