java - Websphere 7 MQueue : how to access queue depth from Java?

Question

我想编写一些代码来监视 Websphere 7 MQ 上的队列大小。这是我想出的代码

   MQEnvironment.hostname = "10.21.1.19"; 
   MQEnvironment.port = 1414;
   MQEnvironment.channel = "SYSTEM.CDEF.SVRCONN";
   MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES);

   MQQueueManager qMgr = new MQQueueManager("MYQMGR");

   MQQueue destQueue = qMgr.accessQueue("PUBLISH", MQC.MQOO_INQUIRE);
   System.out.println(destQueue.getCurrentDepth());
   destQueue.close();
   qMgr.disconnect();

我如何知道“ channel ”是什么？

我如何知道传递给 MQQueueManager 的队列管理器名称是什么？

或者我应该看看其他 API 吗？

我需要它与 WRS 7 SIB 和 MQ 配合使用。

谢谢杰夫·波特

Answer 1

我使用了 WS 7.0.1.1 中的 jar

com.ibm.mq.jarcom.ibm.mq.jmqi.jarcom.ibm.mq.jmqi.system.jarcom.ibm.mq.commonservices.jarcom.ibm.mq.headers..jarcom.ibm.mq.jmqi.remote.jar

我从“IBM Webshpere MQ Explorer”(树中的客户端连接节点)获取了队列管理器名称和 channel 名称

    import com.ibm.mq.MQEnvironment;
    import com.ibm.mq.MQQueue;
    import com.ibm.mq.MQQueueManager;
    import com.ibm.mq.constants.CMQC;
    int openOptions = CMQC.MQOO_INQUIRE + CMQC.MQOO_FAIL_IF_QUIESCING + CMQC.MQOO_INPUT_SHARED;

    MQEnvironment.hostname = "10.2.51.19";
    MQEnvironment.port = 1414;
    MQEnvironment.channel = "SW1_QM_CH1";

    MQQueueManager qMgr = new MQQueueManager("SW1_QM");

    MQQueue destQueue = qMgr.accessQueue("E_RETRY",   openOptions);
    System.out.println("E_RETRY size:" + destQueue.getCurrentDepth());
    destQueue.close();
    qMgr.disconnect();

希望这对其他人有帮助!