java如何在同一函数中浏览来自2个不同MQQueue的所有消息?
我的目的是列出Java应用程序中一组MQ队列中消息的相关ID
这是代码片段
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'.
这是我运行代码时遇到的错误。请注意,当我从下一个队列的队列中获取消息时,会发生错误。我已成功浏览第一个队列的所有邮件。但当我浏览第二个队列中的第一条消息时,我得到了上面的错误。任何人都可以帮助解决此错误
# 1 楼答案
这里有几点需要注意:
第一个是因为您正在初始化第一个
for
循环之外的MQMessage
对象。它必须位于第二个for
循环内,因为当MQQueue.get
调用返回时,MQ用MessageId
、CorrelationId
、消息体等填充该对象。如果使用相同的MQMessage
对象实例再次进行get
调用,则实际上是在尝试获取具有先前检索到的消息的MessageId的消息。此调用失败,原因码为2033关于您的代码,没有其他几点
1)必须在第二个
for
循环中执行new MQGetMessageOptions()
2)您使用的是浏览第一个选项。这将只浏览第一条消息。要浏览所有消息,必须使用
BROWSE_NEXT
选项执行get
。打开队列时,浏览光标在逻辑上位于队列上第一条消息的前面。这意味着,如果在accessQueue
呼叫后立即进行get
呼叫,则可以使用MQGMO_BROWSE_NEXT
选项浏览第一条消息;您不必使用MQGMO_BROWSE_FIRST
选项3)如果队列仅为
browse
打开,则无需指定MQConstants.MQOO_OUTPUT | MQConstants.MQOO_INQUIRE
打开选项4)getCurrentDepth()方法在调用时返回队列深度。在应用程序浏览时,其他应用程序可能会从同一队列中获取消息。在这种情况下,当前队列深度将更改,但您的应用程序不会收到更改通知。因此,您不必使用
dfdaQ.getCurrentDepth()
,只需在while
循环中使用MQGMO_BROWSE_NEXT
选项即可。当没有要浏览的消息时,get调用将返回2033原因码。您可以检查此原因码并退出while循环