IBM MQ系列编程2-----------发送消息到队列中

ddddddf

import com.ibm.mq.*;
import java.util.Properties;

public class MQSender
{
  // define the name of the QueueManager
  private static String qManager;
  // and define the name of the Queue
  private static String qName;
   
  // main method: simply call the runSample() method
  public static void main(String args[])
  {
     if (args == null || args.length != 2)
     {
        System.out.println("need two arguments: <Queue Name> <message>");
System.exit(0);
      }
        new MQSender().runSender(args);
    }

    public void runSender(String args[])
    {
      qName = args[0];
      qManager = System.getProperty ("message.queue.manager");
      try
      {
         // Create a connection to the QueueManager
         System.out.println("Connecting to queue manager: "+qManager);
MQEnvironment.channel = System.getProperty ("message.chanel.name");
MQEnvironment.hostname = System.getProperty ("message.queue.server");
MQEnvironment.port = new Integer ((System.getProperty ("message.queue.port"))).intValue();
MQEnvironment.CCSID = new Integer ((System.getProperty ("message.queue.ccsid"))).intValue();

         MQQueueManager qMgr = new MQQueueManager(qManager);

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

         // Now specify the queue that we wish to open and the open options
         System.out.println("Accessing queue: "+qName);
         MQQueue queue = qMgr.accessQueue(qName, openOptions);

         // Define a simple WebSphere MQ Message ...
MQMessage msg = new MQMessage();
         // ... and write some text in UTF8 format
   
msg.writeString (args[1]);
         // Specify the default put message options
         MQPutMessageOptions pmo = new MQPutMessageOptions();

         // Put the message to the queue
         System.out.println("Sending a message...");
         queue.put(msg);

         // Close the queue
         System.out.println("Closing the queue");
         queue.close();

         // Disconnect from the QueueManager
         System.out.println("Disconnecting from the Queue Manager");
         qMgr.disconnect();
         System.out.println("Done!");
      }
      catch (MQException ex) {
            System.out.println("A WebSphere MQ Error occured : Completion Code "
                    + ex.completionCode + " Reason Code " + ex.reasonCode);
        }
        catch (java.io.IOException ex) {
            System.out.println("An IOException occured whilst writing to the message buffer: "
                    + ex);
        }
    }
}