执行该管理动作之前需要先创建对象工厂,然后才能使用该对象工厂创建可以执行该管理动作的对象。
以下代码演示了如何使用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) {
//异常处理代码
}
...