Javaのサンプルコーディング
コーディング例を次に示します。
import JP.co.Hitachi.soft.MQ.Access.*;
// import the MQAccess package
public class MQAccessSample
{
private String QMgrName = " "; // queue manager name
private MQQueueManager QMgr; // MQQueueManager object
public MQAccessSample()
{
try {
// connect to the queue manager
QMgr = new MQQueueManager(QMgrName);
// set the open options
int openOptions = MQC.MQOO_OUTPUT |
MQC.MQOO_INPUT_AS_Q_DEF ;
// open the queue
MQQueue LocalQ =
QMgr.accessQueue("dynq1", openOptions, null,
null, null);
// create a message object
MQMessage PutMessage = new MQMessage();
// UTF format message data
PutMessage.writeUTF("******** sample put data ********");
// set the put message options
MQPutMessageOptions mqpmo= new MQPutMessageOptions();
mqpmo.options = MQC.MQPMO_SYNCPOINT;
// begin local transaction
QMgr.begin();
// put the message
LocalQ.put(PutMessage, mqpmo);
// commit local transaction
QMgr.commit();
// create a message object
MQMessage GetMessage = new MQMessage();
// set the get message id
GetMessage.messageId = PutMessage.messageId;
// set the get message options
MQGetMessageOptions mqgmo= new MQGetMessageOptions();
mqgmo.options = MQC.MQGMO_SYNCPOINT |
MQC.MQGMO_NO_WAIT;
// begin local transaction
QMgr.begin();
// get the message
LocalQ.get(GetMessage, mqgmo);
// commit local transaction
QMgr.commit();
// display the get message
String msgText = GetMessage.readUTF();
System.out.println("The message is: " + msgText);
// close the queue
LocalQ.close();
// disconnect from the queue manager
QMgr.disconnect();
}
catch (MQException ex)
{
// MQ error
System.out.println
("An MQ error occurred : Completion code " +
ex.completionCode + " Reason code " + ex.reasonCode);
}
catch (java.io.IOException ex)
{
// buffer error
System.out.println
("An error occurred whilst writing to the buffer:"
+ ex);
}
}
public static void main(String args[])
{
// execute this sample program
MQAccessSample sample = new MQAccessSample();
}
}