首页 | 新闻 | 新品 | 文库 | 方案 | 视频 | 下载 | 商城 | 开发板 | 数据中心 | 座谈新版 | 培训 | 工具 | 博客 | 论坛 | 百科 | GEC | 活动 | 主题月 | 电子展
返回列表 回复 发帖

Linux 上的 WebSphere MQ 开发快速入门(3)

Linux 上的 WebSphere MQ 开发快速入门(3)

MQGetMQGet 类(如下所示)非常简单——从指定的队列检索消息,并将其写入到标准输出。可以通过使用重定向将消息存储在文件中。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
package mqconn;

import com.ibm.mq.MQException;

public class MQGet extends MQConnector
{
  public MQGet()
  {
     
  }
   
  public String getMessages(String[] args) throws MQException
  {
   String message=getMessageFromQueue();
   return message;
     
  }
   
  public static void main(String[] args)
  {
    MQGet mqget = new MQGet();
    MQConnector.DEBUG=false;
    try
    {
      mqget.initMq();
      mqget.openQueue();

      String msg=mqget.getMessages(args);
      if(msg!=null)
      {
        System.out.println(msg);      
      }
      
      mqget.closeQueue();
      mqget.disconnectMq();      
    }
    catch (Exception e)
    {
      e.printStackTrace();
      System.out.println("Usage: "+mqget.getClass().getName()+" ");
    }
  }
}




MQGet 使用  文件中指定的队列管理器和队列。下一部分将给出一些可供进行测试的示例用例。
返回列表