2016-06-20 32 views
0

我正在嘗試發送消息並將消息接收到IBM MQ lite,我在c驅動器上提取了mqlight-developer-1.0.2.0-L151130.2mqlight-distribution-1.0.2016020300。我也下載了所需的jar 谷歌GSON 2.2.4, 的logback 1.1.2, 阿帕奇的Netty 4.0.21.Final, Stateless4J 2.5.0, SLF4J 1.7.5 共享SSL 0.3.11 com.ibm。 mqlight如何在IBM MQ Light中使用示例應用程序

我開始使用Mq Light和UI, 要運行helloWorld程序,我遇到了一些困難。我怎樣才能做到這一點

+0

推送消息請提供您有難度的更多信息。你看到什麼錯誤? – ValerieLampkin

回答

0

使用此代碼將在IBM MQ精簡版

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