12.6. 管理传输队列

执行该管理动作之前需要先创建对象工厂,然后才能使用该对象工厂创建可以执行该管理动作的对象。

以下代码演示了如何使用API提供的功能管理MQ服务器上的传输队列。

try {
    //在执行下面的代码之前,需要先创建对象工厂,假设其名称为:factory
    //使用createMqManager创建一个IMqManager的实现类的对象,该对象用于管理网络上某台MQ服务器,
    //要管理的服务器由路由名参数指定,该对象采用默认的120秒请求超时时间
    IMqManager mqManager = factory.createMqManager("Admined Server Router Name");
    //创建一个队列管理器,该管理器用于管理一个传输队列。创建的时候需
    //要指定传输的消息的目的地。
    IQueueManager qManager = mqManager.createTransportQueueManager ("RouterB");
    Collection<MessageIdentifier> msgIds = qManager.getAllMessages();
    Iterator<MessageIdentifier> ite = msgIds.iterator();
    while (ite.hasNext()) {
        MessageIdentifier msgId = ite.next();
        String jmsMsgId = msgId.getJmsMessageId(); 
        Message msg = qManager.getMessage(jmsMsgId);
        ...
    }
    ...  
} catch (JmsAdminException e) {
    //异常处理代码
}
...