JMS API 无法浏览消息，IBM API 可以

Question

我当前的应用程序逻辑使用 'PROCESS' WMQ 队列的深度来确定作业是否正在由 IIB9 工作流处理。如果工作流正在处理消息，则应用程序会等待该工作流结束。工作流结束后，'PROCESS' 队列将使用 GET 操作清空，应用程序发送序列中的其他消息进行处理。我正在使用 JMS 选择器来区分工作流并行处理的多条消息。

问题在于确定队列的深度。 JMS API 给出的深度为 0，而 IBM API 给出的深度为 1（这是预期的）。不幸的是，我不能使用 IBM API 作为我使用一些复杂消息选择器的逻辑。

有人见过这种奇怪的行为吗？请注意，在进行尺寸检查时，IIB9 工作流程正在进行中。是否有要调整的设置？

JMS 代码（为清楚起见删除了消息选择器）：

public class QDepthJMS {

public static void main(String[] a) throws Exception {
    MQConnectionFactory factory = new MQConnectionFactory();
    factory.setTransportType(WMQConstants.WMQ_CM_CLIENT);
    factory.setQueueManager("QM01");
    factory.setHostName("10.10.98.15");
    factory.setPort(1414);
    factory.setChannel("Java.Clients");

    MQConnection connection = (MQConnection) factory.createConnection();
    connection.start();

    MQSession session = (MQSession) connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

    MQQueue queue = (MQQueue) session.createQueue("queue:///PROCESS");
    MQQueueBrowser browser = (MQQueueBrowser) session.createBrowser(queue); 

    Enumeration<Message> msgs = browser.getEnumeration();
    int count =0;
    if (msgs.hasMoreElements()) {
        msgs.nextElement();
        ++count;
    }

    System.out.println(count);
}
}

IBM API (Check MQ queue depth):

public class QDepth {

private final String host;
private final int port;
private final String channel;
private final String manager;
private final MQQueueManager qmgr;

public QDepth(String host, int port, String channel, String manager) throws MQException {
    this.host = host;
    this.port = port;
    this.channel = channel;
    this.manager = manager;
    this.qmgr = createQueueManager();
}

public int depthOf(String queueName) throws MQException {
    MQQueue queue = qmgr.accessQueue(queueName, MQC.MQOO_INQUIRE | MQC.MQOO_INPUT_AS_Q_DEF, null, null, null);
    return queue.getCurrentDepth();
}

@SuppressWarnings("unchecked")
private MQQueueManager createQueueManager() throws MQException {
    MQEnvironment.channel = channel;
    MQEnvironment.port = port;
    MQEnvironment.hostname = host;
    MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES);
    return new MQQueueManager(manager);
}

public static void main(String[] a) throws Exception {
    QDepth qd = new QDepth("10.10.98.15, 1414, "Java.Clients", "QM01");
    System.out.println(qd.depthOf("PROCESS"));
}
}

Answer 1

您没有比较 "like with like" - IBM API 查询队列深度，即队列中有多少消息，但 JMS API 正在浏览消息并计算他们。他们有不同的正当理由 - 通常的原因是有人将消息放在工作单元（同步点）下并且尚未提交 - 因此在这一点上你运行 IBM API 它会说队列中有 1 条消息（有...）但它不可获取/不可浏览，因为它尚未提交。

您可以通过运行mqsc DIS QSTATUS 使用运行mqsc（可能还有 GUI）验证这一点，并查看 UNCOM 属性 - 请参阅 http://www-01.ibm.com/support/docview.wss?uid=swg21636775

JMS API 无法浏览消息，IBM API 可以

JMS API cannot browse messages, IBM API can

java

jms

ibm-mq