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();
 }
}