如何在同一个函数中浏览来自两个不同MQQueue的所有消息？

Question

我的目的是列出Java应用程序中一组MQ队列中消息的相关is。

这是代码片段

public void populateCorrelationIds() throws MQException{
    int openOptions = MQConstants.MQOO_INPUT_AS_Q_DEF | MQConstants.MQOO_OUTPUT | MQConstants.MQOO_INQUIRE | MQConstants.MQOO_BROWSE;
    String qNames[0] = BAY10.CISCHGX.DFDA;
    String qNames[1] = BAYSF11.MSFCHGX.DFDA;
    MQMessage messageGet = new MQMessage();
    for(String q : qNames){
        MQQueue dfdaQ  = qMgr.accessQueue(q, openOptions);
        MQGetMessageOptions gmo = new MQGetMessageOptions();
        gmo.options = MQConstants.MQGMO_BROWSE_FIRST| MQConstants.MQGMO_WAIT;
        gmo.waitInterval = 4000;
        int j = dfdaQ.getCurrentDepth();
        for(int i=0;i<j;i++)
        {
            dfdaQ.get(messageGet,gmo);  //Error generated here when getting message for qNames[1]
            byte[] correlId= messageGet.correlationId;
        }
    }
}

下面是我正在犯的错误--

MQJE001: Completion Code '2', Reason '2033'. com.ibm.mq.MQException: 
MQJE001: Completion Code '2', Reason '2033'. at    
com.ibm.mq.MQDestination.getInt(MQDestination.java:655) at 
com.ibm.mq.MQDestination.get(MQDestination.java:459) at 
Utility.populateCorrelationIds(Utility.java:152) at 
Utility.main(Utility.java:64) MQJE001: Completion Code '2', Reason '2033'.

这是我在运行代码时遇到的错误。请注意，当我从队列中得到下一个队列的消息时，会发生错误。我能够成功地浏览第一个队列的所有消息。但是，一旦我浏览第二个队列中的第一个消息，我就会得到上面的错误。有人能帮忙解决这个错误吗。

Answer 1

这里有几点需要注意：

第一个原因是在第一个MQMessage循环之外初始化for对象。它必须位于第二个for循环中，因为当MQ调用返回时，MQ将该对象填充为MessageId、CorrelationId、消息体等。如果您再次使用相同的get对象实例进行MQMessage调用，则实际上正在尝试使用以前检索到的消息的MessageId获取消息。此调用带2033原因代码失败。

关于您的代码，几乎没有其他要点。

1)您必须在第二个new MQGetMessageOptions()循环中执行for。

2)您使用的是BROWSE_FIRST选项。这将只浏览第一条消息。要浏览所有消息，您必须使用get和BROWSE_NEXT选项。打开队列时，浏览游标在队列上的第一条消息之前逻辑上定位。这意味着，如果在get调用之后立即进行accessQueue调用，则可以使用MQGMO_BROWSE_NEXT选项浏览第一条消息；不必使用MQGMO_BROWSE_FIRST选项。

3)如果只为browse打开队列，则不需要指定MQConstants.MQOO_OUTPUT | MQConstants.MQOO_INQUIRE open选项。

4) getCurrentDepth()方法在调用时返回队列深度。在您的应用程序进行浏览时，可能会有其他应用程序从同一个队列中获取消息。在这种情况下，当前队列深度将发生变化，但不会通知应用程序更改。因此，不必使用dfdaQ.getCurrentDepth()，只需在while循环中使用MQGMO_BROWSE_NEXT选项即可。当没有要浏览的消息时，get调用将返回2033原因代码。您可以检查此原因代码并退出while循环。