Java JMS MQ Beispiel

 public static void main(String\[\] args) {

     MQQueueConnectionFactory cf = new MQQueueConnectionFactory();

     try {

       cf.setHostName("...");
       cf.setPort(1415);
       cf.setTransportType(JMSC.MQJMS\_TP\_CLIENT\_MQ\_TCPIP);
       cf.setQueueManager("...");
       cf.setChannel("SYSTEM.DEF.SVRCONN");
       String qIn = "...";
       String qOut = "...";

       MQQueueConnection connection = (MQQueueConnection) cf.createQueueConnection();
       // create a new Session, which is not transacted
       MQQueueSession session = (MQQueueSession) connection.createQueueSession(false, Session.AUTO\_ACKNOWLEDGE);
       // create queues
       MQQueue queueRead = (MQQueue) session.createQueue(qIn);
       MQQueue queueWrite = (MQQueue) session.createQueue(qOut);
       // if the client on the other side is a non-jms client set this property
       queueWrite.setTargetClient(JMSC.MQJMS\_CLIENT\_NONJMS\_MQ);

       // create a sender	    
       MQQueueSender sender =  (MQQueueSender) session.createSender(queueWrite);
       MQQueueReceiver receiver = null;      
	
       // create the message which will be sent over MQ
       JMSTextMessage message = (JMSTextMessage) session.createTextMessage(dat);     
      // define the message type (not really necessary, depends from the client on the other side)
      message.setJMSType(MQC.MQFMT\_STRING);
      // set a correlation ID
      message.setJMSCorrelationID("MyIdSomethingElse" + System.currentTimeMillis());
      // set the replay queue
      message.setJMSReplyTo(queueRead);
	    
      // lets start the connection
      connection.start();

      // send the JMS-Message		
      sender.send(message);

      // create the selector to retrieve only the right response
      // the combination of message and correlation ID depends the individually defined constraints		    
      // it is wise to use the correlation and message ID for the selector, cause this are
      // faster as some other properties
      // Hint: the format for correlation ID is
      // JMSCorrelationID = 'ID:AF01CE....hex string...'
      // the prefix 'ID' is mandatory. However the message ID contains the fragment 'ID:'
      String selector = "JMSCorrelationID = 'ID:" + dumpId2Hex(message.getJMSCorrelationIDAsBytes()) + 
                             "' AND JMSMessageID = '" + message.getJMSMessageID() + "'";

      // create a receiver with the defined selector	    
      receiver = (MQQueueReceiver) session.createReceiver(queueRead, selector);

      // receive the response (with match the filter in the selector). This call blocks max. 20000 ms 	    
      Message receivedMessage = receiver.receive(20000);

      // check if message is received and a text message
      if (receivedMessage instanceof TextMessage) {
           // get the content...		    	
          String replyString = ((TextMessage) receivedMessage).getText();
     }

     // close everything...
     sender.close();
     receiver.close();
     session.close();
     connection.close();		    

       

       }
    catch (JMSException jmsex) {
    	log.error("JMSException", jmsex);
    }
    catch (Exception ex) {
    	log.error("An other error occurred.", ex);
    }
 }