So verwenden Sie die Beispielanwendung in IBM MQ Light

Question

Ich versuche, die Nachricht zu senden und die Nachricht an IBM MQ lite zu senden, extrahierte ich die mqlight-developer-1.0.2.0-L151130.2 und mqlight-distribution-1.0.2016020300 auf c-Laufwerk. Ich heruntergeladen auch die erforderliche jar Google Gson 2.2.4, Logback 1.1.2, Apache Netty 4.0.21.Final, Stateless4J 2.5.0 SLF4J 1.7.5 Commons SSL 0.3.11 com.ibm. mqlight

Ich startete die Mq Light und UI erscheint, Um das HelloWorld-Programm zu starten bekomme ich einige Schwierigkeiten. Wie kann ich das tun

Answer 1

Verwenden Sie diesen Code es

package com.Queue; 
import com.ibm.mqlight.api.ClientOptions; 

import com.ibm.mqlight.api.Delivery; 
import com.ibm.mqlight.api.DestinationAdapter; 
import com.ibm.mqlight.api.NonBlockingClient; 
import com.ibm.mqlight.api.NonBlockingClientAdapter; 
import com.ibm.mqlight.api.StringDelivery; 


public class SendReceive2 
{ 
    public static void main(String[] cmdline) 
    { 
     ClientOptions clientOpts = ClientOptions.builder().setCredentials("ad", "jms123").build(); 



     NonBlockingClient.create("amqp://localhost", clientOpts, new NonBlockingClientAdapter<Void>() 
     { 

      public void onStarted(NonBlockingClient client, Void context) 
      { 
       client.subscribe("JmsQueue", new DestinationAdapter<Void>() 
       { 
        public void onMessage(NonBlockingClient client, Void context, Delivery delivery) 
        { 
         if (delivery.getType() == Delivery.Type.STRING) 
          System.out.println(((StringDelivery)delivery).getData()); 
        } 
       }, null, null); 
      } 
     }, null); 





     NonBlockingClient.create("amqp://localhost", clientOpts, new NonBlockingClientAdapter<Void>() 
     { 
      public void onStarted(NonBlockingClient client, Void context) 
      { 
       client.send("JmsQueue", "Jms Queue is Formed!", null); 
      } 

     }, null); 






    }//main 


}//class